public class SpatialJoin extends SpatialJoin
Partitioning
is required to perform the spatial join. A spatial join can be executed as follows:
SpatialJoin
instancepreprocess(Job)
configure(Job)
SpatialJoin.preprocess(JobConf)
.Constructor and Description |
---|
SpatialJoin() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Job job)
Validates and adds the current parameters to the job configuration
|
static void |
main(java.lang.String[] args) |
boolean |
preprocess(Job job)
Checks whether partitioning is required and if so, it runs the partitioning process.
|
int |
run(java.lang.String[] args) |
getCmdOptions, getCurrentCmdArgs, getOutput, getPartitioningResultPath, getSamplingRatio, getSpatialOperationConfig, processArgs, setPartitioningResultPath, setSamplingRatio, setSpatialOperationConfig
addInputDataSet, getInputs, getMultipleInputDataSetsParams, removeInputDataSet, setInputDataSets
getCmdOptionsWithInputDataSets, getCurrentCmdArgsAsString, getInput, getInputDataSet, getInputFormatClass, getJarClass, getRecordInfoProviderClass, getSpatialConfig, setInput, setInputDataSet, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig
public void configure(Job job) throws java.lang.Exception
BaseJob
configure
in class SpatialJoin
job
- a job instancejava.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public boolean preprocess(Job job) throws java.lang.Exception
SpatialJoin
preprocess
in class SpatialJoin
job
- the job configurationjava.lang.Exception
public int run(java.lang.String[] args) throws java.lang.Exception
run
in class SpatialJoin
java.lang.Exception
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.