oracle.spatial.hadoop.vector.mapred.job

Class IndexedInputBaseJob<K,V>

java.lang.Object

org.apache.hadoop.conf.Configured

oracle.spatial.hadoop.vector.mapred.job.BaseJob<K,V>

oracle.spatial.hadoop.vector.mapred.job.IndexedInputBaseJob<K,V>

Type Parameters:

K - the type of the input keys

V - the type of the input values

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

Direct Known Subclasses:

Binning, Categorization, SpatialFilter

public abstract class IndexedInputBaseJob<K,V>
extends BaseJob<K,V>

Base implementation for jobs which accept a spatial index as input.

Field Summary

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

argsp, inputDataSet, jarClass, jobRegEntryPath, proxyIDS

Constructor Summary

Constructors

Constructor and Description
IndexedInputBaseJob() Creates a new instance

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getIndexMetadataDir() Gets the path to the directory where the index metadata is located
java.lang.String	getIndexName() Gets the name of the spatial index to be used as input
protected SpatialIndexInputDataSet	getProxyIDS()
boolean	isInputIndex() Tells whether the input path is the path to a spatial index.
void	setIndexMetadataDir(java.lang.String indexMetadataDir) Sets the path to the directory where the index metadata is located
void	setIndexName(java.lang.String indexName) Sets the name of the spatial index to be used as input
void	setInputIndex(boolean inputIndex) Sets whether the input path is the path to a spatial index.
protected void	updateInputDataSet()

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

addJobRegistryEntry, addJobRegistryEntry, addJobRegistryEntry, configure, configure, createJob, createJob, createJob, createJob, createJobConf, createJobConf, createJobConf, getCmdOptions, getCmdOptionsWithInputDataSets, getCmdOptionsWithInputDataSets, getCurrentCmdArgs, getCurrentCmdArgsAsString, getCurrentCmdArgsAsString, getInput, getInputDataSet, getInputDataSetCmdParserHandler, getInputDataSetConfiguratorHandler, getInputFormatClass, getJarClass, getOutput, getRecordInfoProviderClass, getSpatialConfig, processArgs, runJob, runJob, setInput, setInputDataSet, setInputFormatClass, setJarClass, setOutput, setRecordInfoProviderClass, setSpatialConfig

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.util.Tool

run

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Constructor Detail

IndexedInputBaseJob

public IndexedInputBaseJob()

Creates a new instance

Method Detail

getProxyIDS

protected SpatialIndexInputDataSet getProxyIDS()

getIndexMetadataDir

public java.lang.String getIndexMetadataDir()

Gets the path to the directory where the index metadata is located

Returns:

a path

setIndexMetadataDir

public void setIndexMetadataDir(java.lang.String indexMetadataDir)

Sets the path to the directory where the index metadata is located

Parameters:

indexMetadataDir - a path

getIndexName

public java.lang.String getIndexName()

Gets the name of the spatial index to be used as input

Returns:

a spatial index name

setIndexName

public void setIndexName(java.lang.String indexName)

Sets the name of the spatial index to be used as input

Parameters:

indexName - a spatial index name

isInputIndex

public boolean isInputIndex()

Tells whether the input path is the path to a spatial index. It it used when the input path is set instead of the index name.

Returns:

true if the input path is a spatial index

setInputIndex

public void setInputIndex(boolean inputIndex)

Sets whether the input path is the path to a spatial index. It it used when the input path is set instead of the index name.

Parameters:

inputIndex - true if the input path is a spatial index

updateInputDataSet

protected void updateInputDataSet()

Overrides:

updateInputDataSet in class BaseJob<K,V>