oracle.spatial.hadoop.vector.mapreduce.input

Class FileInputFormatAdapter<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<K,V>

org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>

oracle.spatial.hadoop.vector.mapreduce.input.FileInputFormatAdapter<K,V>

Direct Known Subclasses:

NoSQLFileInputFormat

public class FileInputFormatAdapter<K,V>
extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileInputFormatAdapter.FileRecordReaderAdapter<K,V>
static class	FileInputFormatAdapter.FileSplitAdapter

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
FileInputFormatAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.RecordReader<K,V>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
protected org.apache.hadoop.mapreduce.InputFormat<K,V>	getInputFormat(org.apache.hadoop.conf.Configuration conf)
java.util.List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context)
static <K,V> void	setInputFormatClass(java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat<K,V>> inputFormatClass, org.apache.hadoop.conf.Configuration conf)
protected FileInputFormatAdapter.FileSplitAdapter	toFileSplitAdapter(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.JobContext context)
protected java.util.List<org.apache.hadoop.mapreduce.InputSplit>	toFileSplits(java.util.List<org.apache.hadoop.mapreduce.InputSplit> inSplits, org.apache.hadoop.mapreduce.JobContext context)

Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat

addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, isSplitable, listStatus, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize

Methods inherited from class java.lang.Object

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

Field Detail

CONF_INPUT_FORMAT

public static final java.lang.String CONF_INPUT_FORMAT

See Also:

Constant Field Values

Constructor Detail

FileInputFormatAdapter

public FileInputFormatAdapter()

Method Detail

setInputFormatClass

public static <K,V> void setInputFormatClass(java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat<K,V>> inputFormatClass,
                                             org.apache.hadoop.conf.Configuration conf)

getInputFormat

protected org.apache.hadoop.mapreduce.InputFormat<K,V> getInputFormat(org.apache.hadoop.conf.Configuration conf)

getSplits

public java.util.List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                                 throws java.io.IOException

Overrides:

getSplits in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat<K,V>

Throws:

java.io.IOException

toFileSplits

protected java.util.List<org.apache.hadoop.mapreduce.InputSplit> toFileSplits(java.util.List<org.apache.hadoop.mapreduce.InputSplit> inSplits,
                                                                              org.apache.hadoop.mapreduce.JobContext context)
                                                                       throws java.io.IOException

Throws:

java.io.IOException

toFileSplitAdapter

protected FileInputFormatAdapter.FileSplitAdapter toFileSplitAdapter(org.apache.hadoop.mapreduce.InputSplit split,
                                                                     org.apache.hadoop.mapreduce.JobContext context)
                                                              throws java.io.IOException,
                                                                     java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<K,V> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                        org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                 throws java.io.IOException,
                                                                        java.lang.InterruptedException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<K,V>

Throws:

java.io.IOException

java.lang.InterruptedException