K
- the type of the input keysV
- the type of the input valuespublic class SuggestService<K,V> extends BaseJob<K,V>
Modifier and Type | Class and Description |
---|---|
static class |
SuggestService.MVSMapper<K,V>
Maps location texts from input records to a suggested feature/layer returned by MVSuggest
|
static class |
SuggestService.SuggestServiceReducer<K,V>
Collects all the different texts associated to each feature id/layer
|
Constructor and Description |
---|
SuggestService() |
Modifier and Type | Method and Description |
---|---|
void |
configure(org.apache.hadoop.mapred.JobConf conf)
Validates and adds the current parameters to the job configuration
|
java.lang.String |
getCmdOptions()
Gets a description of the arguments expected from command line.
|
MVSConfig |
getMvsConf()
Gets the MVSuggest configuration
|
static 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 |
setMvsConf(MVSConfig mvsConf)
Sets the MVSuggest configuration
|
configure, createJob, createJob, createJob, createJob, createJobConf, createJobConf, createJobConf, getInput, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, setInput, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig
public void setMvsConf(MVSConfig mvsConf)
mvsConf
- the MVSuggest configurationpublic MVSConfig getMvsConf()
public java.lang.String getCmdOptions()
BaseJob
getCmdOptions
in class BaseJob<K,V>
public 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 void configure(org.apache.hadoop.mapred.JobConf conf) throws java.lang.Exception
BaseJob
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception