K
- the type of the input keysV
- the type of the input valuespublic class Binning<K,V> extends IndexedInputBaseJob<K,V>
Constructor and Description |
---|
Binning() |
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf jobConf)
Validates and adds the current parameters to the job configuration
|
BinningConfig |
getBinConf()
Gets the binning configuration
|
java.lang.String |
getCmdOptions()
Gets a description of the arguments expected from command line.
|
java.util.Map<java.lang.String,java.lang.Object> |
getCurrentCmdArgs(Configuration conf)
Returns the current driver properties in a map where each key-value is a name and value of a command line argument.
|
static <K,V> void |
main(java.lang.String[] args) |
void |
processArgs(java.lang.String[] args, Configuration conf)
Extracts and validates arguments from the command line
|
int |
run(java.lang.String[] args) |
void |
setBinConf(BinningConfig binConf)
Sets the binning configuration
|
getIndexMetadataDir, getIndexName, isInputIndex, setIndexMetadataDir, setIndexName, setInputIndex
getCmdOptionsWithInputDataSets, getCurrentCmdArgsAsString, getInput, getInputDataSet, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, setInput, setInputDataSet, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig
public void configure(JobConf jobConf) throws java.lang.Exception
BaseJob
public BinningConfig getBinConf()
public java.lang.String getCmdOptions()
BaseJob
getCmdOptions
in class BaseJob<K,V>
public java.util.Map<java.lang.String,java.lang.Object> getCurrentCmdArgs(Configuration conf)
BaseJob
getCurrentCmdArgs
in class BaseJob<K,V>
conf
- a job configurationpublic static <K,V> void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public void processArgs(java.lang.String[] args, Configuration conf) throws java.lang.Exception
BaseJob
processArgs
in class BaseJob<K,V>
args
- arguments from the command lineconf
- the job configurationjava.lang.Exception
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public void setBinConf(BinningConfig binConf)
binConf
- a binning configurationCopyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.