oracle.spatial.hadoop.vector.mapred.job

Class MultipleInputsJob

java.lang.Object

Configured

oracle.spatial.hadoop.vector.mapred.job.BaseJob<java.lang.Object,java.lang.Object>

oracle.spatial.hadoop.vector.mapred.job.MultipleInputsJob

Direct Known Subclasses:

MBR, Partitioning, SpatialJoin

public abstract class MultipleInputsJob
extends BaseJob<java.lang.Object,java.lang.Object>

Base driver class for jobs that accept more than one input data sets which are processed by the same mapper.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
MultipleInputsJob() Creates a new instance

Method Summary

Modifier and Type	Method and Description
void	addInputDataSet(InputDataSet input)
java.util.List<InputDataSet>	getInputs()
static java.lang.String[][]	getMultipleInputDataSetsParams(java.lang.String inputDataSetListStr)
void	processArgs(java.lang.String[] args, Configuration conf) Extracts and validates arguments from the command line
boolean	removeInputDataSet(InputDataSet input)
void	setInputDataSets(java.util.List<InputDataSet> inputs)

Methods inherited from class oracle.spatial.hadoop.vector.mapred.job.BaseJob

configure, configure, getCmdOptions, getCmdOptionsWithInputDataSets, getCurrentCmdArgs, getCurrentCmdArgsAsString, getInput, getInputDataSet, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, setInput, setInputDataSet, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultipleInputsJob

public MultipleInputsJob()

Creates a new instance

Method Detail

addInputDataSet

public void addInputDataSet(InputDataSet input)

getInputs

public java.util.List<InputDataSet> getInputs()

getMultipleInputDataSetsParams

public static java.lang.String[][] getMultipleInputDataSetsParams(java.lang.String inputDataSetListStr)

processArgs

public void processArgs(java.lang.String[] args,
                        Configuration conf)
                 throws java.lang.Exception

Description copied from class: BaseJob

Extracts and validates arguments from the command line

Overrides:

processArgs in class BaseJob<java.lang.Object,java.lang.Object>

Parameters:

args - arguments from the command line

conf - the job configuration

Throws:

java.lang.Exception

removeInputDataSet

public boolean removeInputDataSet(InputDataSet input)

setInputDataSets

public void setInputDataSets(java.util.List<InputDataSet> inputs)