oracle.spatial.hadoop.vector.mapred.input

Class AdapterInputFormat<K,V>

java.lang.Object

<any>

oracle.spatial.hadoop.vector.mapred.input.AdapterInputFormat<K,V>

Type Parameters:

K - The type of the internalInputFormat's keys

V - The type of the internalInputFormat's values

public class AdapterInputFormat<K,V>
extends <any>

This input format works as an adapter for subclasses of the new API' org.apache.hadoop.mapreduce.lib.input.FileInputFormat

The internal InputFormat class must be set using the static method AdapterInputFormat#setInternalInputFormatClass(JobConf, Class)

Note that when using a new API' InputFormat with SpatialIndexingMapper it will be not possible to get the start position for each record so the index' entries will not contain the record pointer information (offset and length).

Author:

hsaucedo

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AdapterInputFormat()

Method Summary

Modifier and Type	Method and Description
void	configure(JobConf conf)
<any>	getInternalInputFormat(JobConf conf) Gets an instance of the class set as the internal input format
static <K,V> java.lang.Class<? extends <any>>	getInternalInputFormatClass(JobConf conf) Gets the internal input format type which is used to actually read the data.
<any>	getRecordReader(InputSplit split, JobConf conf, Reporter reporter)
InputSplit[]	getSplits(JobConf conf, int arg1)
static <K,V> void	setInternalInputFormatClass(JobConf conf, java.lang.Class<? extends <any>> inputFormatClass) Sets the internal input format type which is used to actually read the data.

Methods inherited from class java.lang.Object

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

Field Detail

NEW_INPUT_FORMAT

public static final java.lang.String NEW_INPUT_FORMAT

See Also:

Constant Field Values

Constructor Detail

AdapterInputFormat

public AdapterInputFormat()

Method Detail

configure

public void configure(JobConf conf)

getInternalInputFormat

public <any> getInternalInputFormat(JobConf conf)

Gets an instance of the class set as the internal input format

Parameters:

conf - the job configuration

Returns:

an org.apache.hadoop.mapreduce.lib.input.FileInputFormat instance

getInternalInputFormatClass

public static <K,V> java.lang.Class<? extends <any>> getInternalInputFormatClass(JobConf conf)

Gets the internal input format type which is used to actually read the data.

Parameters:

conf - the job configuration

Returns:

a class of type org.apache.hadoop.mapreduce.lib.input.FileInputFormat

getRecordReader

public <any> getRecordReader(InputSplit split,
                             JobConf conf,
                             Reporter reporter)
                      throws java.io.IOException

Throws:

java.io.IOException

getSplits

public InputSplit[] getSplits(JobConf conf,
                              int arg1)
                       throws java.io.IOException

Throws:

java.io.IOException

setInternalInputFormatClass

public static <K,V> void setInternalInputFormatClass(JobConf conf,
                                                     java.lang.Class<? extends <any>> inputFormatClass)

Sets the internal input format type which is used to actually read the data.

Parameters:

conf - the job configuration

inputFormatClass - a class of type org.apache.hadoop.mapreduce.lib.input.FileInputFormat