K
- the type of the input keysV
- the type of the input valuespublic class Binning<K,V> extends IndexedInputBaseJob<K,V>
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
ARG_AGGR_FIELDS |
protected static java.lang.String |
ARG_CELL_SHAPE |
protected static java.lang.String |
ARG_CELL_SIZE |
protected static java.lang.String |
ARG_GRID_MBR |
protected BinningConfig |
binConf |
protected static java.lang.String |
RESULT_FILE_NAME |
argsp, inputDataSet, jarClass, jobRegEntryPath, proxyIDS
Constructor and Description |
---|
Binning() |
Modifier and Type | Method and Description |
---|---|
void |
configure(org.apache.hadoop.mapred.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(org.apache.hadoop.conf.Configuration conf)
Returns the current driver properties in a map where each key-value is a name and value of a command line argument.
|
protected InputDataSetCmdArgsParserHandler |
getInputDataSetCmdParserHandler(org.apache.hadoop.conf.Configuration conf)
Gets the current instance of
InputDataSetCmdArgsParserHandler used to parse command line parameters for the input data set |
protected InputDataSetConfiguratorHandler |
getInputDataSetConfiguratorHandler(org.apache.hadoop.conf.Configuration conf)
Returns the current instance of
InputDataSetConfiguratorHandler used to configure the input data set |
static <K,V> void |
main(java.lang.String[] args) |
void |
processArgs(java.lang.String[] args, org.apache.hadoop.conf.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, getProxyIDS, isInputIndex, setIndexMetadataDir, setIndexName, setInputIndex, updateInputDataSet
addJobRegistryEntry, addJobRegistryEntry, addJobRegistryEntry, configure, createJob, createJob, createJob, createJob, createJobConf, createJobConf, createJobConf, getCmdOptionsWithInputDataSets, getCmdOptionsWithInputDataSets, getCurrentCmdArgsAsString, getCurrentCmdArgsAsString, getInput, getInputDataSet, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, runJob, runJob, setInput, setInputDataSet, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig
protected static final java.lang.String ARG_CELL_SIZE
protected static final java.lang.String ARG_GRID_MBR
protected static final java.lang.String ARG_AGGR_FIELDS
protected static final java.lang.String ARG_CELL_SHAPE
protected static final java.lang.String RESULT_FILE_NAME
protected BinningConfig binConf
protected InputDataSetConfiguratorHandler getInputDataSetConfiguratorHandler(org.apache.hadoop.conf.Configuration conf)
BaseJob
InputDataSetConfiguratorHandler
used to configure the input data setgetInputDataSetConfiguratorHandler
in class BaseJob<K,V>
conf
- a job configurationInputDataSetConfiguratorHandler
protected InputDataSetCmdArgsParserHandler getInputDataSetCmdParserHandler(org.apache.hadoop.conf.Configuration conf)
BaseJob
InputDataSetCmdArgsParserHandler
used to parse command line parameters for the input data setgetInputDataSetCmdParserHandler
in class BaseJob<K,V>
conf
- a job configurationInputDataSetCmdArgsParserHandler
public BinningConfig getBinConf()
public void setBinConf(BinningConfig binConf)
binConf
- a binning configurationpublic void processArgs(java.lang.String[] args, org.apache.hadoop.conf.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 java.util.Map<java.lang.String,java.lang.Object> getCurrentCmdArgs(org.apache.hadoop.conf.Configuration conf)
BaseJob
getCurrentCmdArgs
in class BaseJob<K,V>
conf
- a job configurationpublic java.lang.String getCmdOptions()
BaseJob
getCmdOptions
in class BaseJob<K,V>
public void configure(org.apache.hadoop.mapred.JobConf jobConf) throws java.lang.Exception
BaseJob
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public static <K,V> void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
Copyright © 2016 Oracle and/or its affiliates. All Rights Reserved.