public final class AffinityMatrixInputJob extends Object
Modifier and Type | Method and Description |
---|---|
static DistributedRowMatrix |
runJob(org.apache.hadoop.fs.Path input,
org.apache.hadoop.fs.Path output,
int dimensions)
A transparent wrapper for the above method which handles the tedious tasks
of setting and retrieving system Paths.
|
static void |
runJob(org.apache.hadoop.fs.Path input,
org.apache.hadoop.fs.Path output,
int rows,
int cols)
Initializes and executes the job of reading the documents containing
the data of the affinity matrix in (x_i, x_j, value) format.
|
public static void runJob(org.apache.hadoop.fs.Path input, org.apache.hadoop.fs.Path output, int rows, int cols) throws IOException, InterruptedException, ClassNotFoundException
public static DistributedRowMatrix runJob(org.apache.hadoop.fs.Path input, org.apache.hadoop.fs.Path output, int dimensions) throws IOException, InterruptedException, ClassNotFoundException
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.