public class Partitioning extends Partitioning
Partitioning.setSamplingRatio(double)
property (by default it is set to 0.1).PARTITION_RESULT_FILE, samplingRatio
inputDataSets, miConf
Constructor and Description |
---|
Partitioning() |
Modifier and Type | Method and Description |
---|---|
void |
configure(org.apache.hadoop.mapreduce.Job job) |
static void |
main(java.lang.String[] args) |
int |
run(java.lang.String[] args) |
boolean |
runFullPartitioningProcess(org.apache.hadoop.mapreduce.Job job)
Runs the full partitioning process.
|
configure, defineGlobaBounds, getCmdOptions, getPathsLength, getSamplePath, getSamplingRatio, processArgs, runFullPartitioningProcess, setSamplingRatio
addInputDataSet, configureInputs, configureInputs, getInputListCmdOptions, getInputs, getMultipleInputDataSetsParams, removeInputDataSet, setInputDataSets
createJob, createJob, createJob, createJob, createJobConf, createJobConf, createJobConf, getInput, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, setInput, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig
public void configure(org.apache.hadoop.mapreduce.Job job) throws java.lang.Exception
configure
in class MultipleInputsJob
java.lang.Exception
public boolean runFullPartitioningProcess(org.apache.hadoop.mapreduce.Job job) throws java.lang.Exception
job
- a jobjava.lang.Exception
public int run(java.lang.String[] args) throws java.lang.Exception
run
in interface org.apache.hadoop.util.Tool
run
in class Partitioning
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception