oracle.spatial.hadoop.vector.mapred.input

Class SpatialIndexTextInputFormat

java.lang.Object

org.apache.hadoop.mapred.FileInputFormat<K,V>

org.apache.hadoop.mapred.SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

oracle.spatial.hadoop.vector.mapred.input.SpatialIndexTextInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

public class SpatialIndexTextInputFormat
extends org.apache.hadoop.mapred.SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Input format used to filter using a given spatial index. The information is filtered based on a minimum bounding rectangle (MBR) specified in the job parameter oracle.spatial.spatialQueryWindow. The parameter oracle.spatial.spatialQueryWindow has to be a string in GeoJSON format. The output will be the records in GeoJSON format. To add the index extra fields to the returned result specify the fields names separated by comma in the job parameter oracle.spatial.index.includeExtraFields.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	SpatialIndexTextInputFormat.SpatialIndexTextRecordReader

Nested classes/interfaces inherited from class org.apache.hadoop.mapred.FileInputFormat

org.apache.hadoop.mapred.FileInputFormat.Counter

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_INCLUDED_EXTRA_FIELDS

Fields inherited from class org.apache.hadoop.mapred.FileInputFormat

INPUT_DIR_RECURSIVE, NUM_INPUT_FILES

Constructor Summary

Constructors

Constructor and Description
SpatialIndexTextInputFormat()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.hadoop.mapred.SequenceFileInputFormat

listStatus

Methods inherited from class org.apache.hadoop.mapred.FileInputFormat

addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, getSplits, isSplitable, makeSplit, makeSplit, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize

Methods inherited from class java.lang.Object

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

Field Detail

CONF_INCLUDED_EXTRA_FIELDS

public static final java.lang.String CONF_INCLUDED_EXTRA_FIELDS

See Also:

Constant Field Values

Constructor Detail

SpatialIndexTextInputFormat

public SpatialIndexTextInputFormat()

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                                                                                  org.apache.hadoop.mapred.JobConf job,
                                                                                                                  org.apache.hadoop.mapred.Reporter reporter)
                                                                                                           throws java.io.IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Overrides:

getRecordReader in class org.apache.hadoop.mapred.SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

java.io.IOException