public class SpectralKMeansDriver extends AbstractJob
Modifier and Type | Field and Description |
---|---|
static int |
BLOCKHEIGHT |
static int |
OVERSAMPLING |
static int |
POWERITERS |
static int |
REDUCERS |
argMap, inputFile, inputPath, outputFile, outputPath, tempPath
Constructor and Description |
---|
SpectralKMeansDriver() |
Modifier and Type | Method and Description |
---|---|
static void |
main(String[] args) |
static void |
run(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path input,
org.apache.hadoop.fs.Path output,
int numDims,
int clusters,
DistanceMeasure measure,
double convergenceDelta,
int maxIterations,
org.apache.hadoop.fs.Path tempDir) |
static void |
run(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path input,
org.apache.hadoop.fs.Path output,
int numDims,
int clusters,
DistanceMeasure measure,
double convergenceDelta,
int maxIterations,
org.apache.hadoop.fs.Path tempDir,
int numReducers,
int blockHeight,
int oversampling,
int poweriters)
Run the Spectral KMeans clustering on the supplied arguments
|
int |
run(String[] arg0) |
addFlag, addInputOption, addOption, addOption, addOption, addOption, addOutputOption, buildOption, buildOption, getAnalyzerClassFromOption, getCLIOption, getConf, getDimensions, getFloat, getFloat, getGroup, getInputFile, getInputPath, getInt, getInt, getOption, getOption, getOption, getOptions, getOutputFile, getOutputPath, getOutputPath, getTempPath, getTempPath, hasOption, keyFor, maybePut, parseArguments, parseArguments, parseDirectories, prepareJob, prepareJob, prepareJob, prepareJob, setConf, setS3SafeCombinedInputPath, shouldRunNextPhase
public static final int REDUCERS
public static final int BLOCKHEIGHT
public static final int OVERSAMPLING
public static final int POWERITERS
public static void run(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path input, org.apache.hadoop.fs.Path output, int numDims, int clusters, DistanceMeasure measure, double convergenceDelta, int maxIterations, org.apache.hadoop.fs.Path tempDir) throws IOException, InterruptedException, ClassNotFoundException
public static void run(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path input, org.apache.hadoop.fs.Path output, int numDims, int clusters, DistanceMeasure measure, double convergenceDelta, int maxIterations, org.apache.hadoop.fs.Path tempDir, int numReducers, int blockHeight, int oversampling, int poweriters) throws IOException, InterruptedException, ClassNotFoundException
conf
- the Configuration to be usedinput
- the Path to the input tuples directoryoutput
- the Path to the output directorynumDims
- the int number of dimensions of the affinity matrixclusters
- the int number of eigenvectors and thus clusters to producemeasure
- the DistanceMeasure for the k-Means calculationsconvergenceDelta
- the double convergence delta for the k-Means calculationsmaxIterations
- the int maximum number of iterations for the k-Means calculationstempDir
- Temporary directory for intermediate calculationsnumReducers
- Number of reducersblockHeight
- oversampling
- poweriters
- IOException
InterruptedException
ClassNotFoundException
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.