oracle.spatial.hadoop.vector.mapreduce.input

Class BaseWrapperInputFormat<K,V>

java.lang.Object

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

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

Direct Known Subclasses:

InputSplitInputFormat, JGeometryKeyInputFormat

public abstract class BaseWrapperInputFormat<K,V>
extends org.apache.hadoop.mapreduce.InputFormat<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.mapreduce.InputFormat<?,?>	iInputFormat

Constructor Summary

Constructors

Constructor and Description
BaseWrapperInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.mapreduce.InputFormat<?,?>	createInternalInputFormat(org.apache.hadoop.conf.Configuration conf)
static RecordInfoProvider<?,?>	createRecordInfoProvider(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass, org.apache.hadoop.conf.Configuration conf)
org.apache.hadoop.mapreduce.InputFormat<?,?>	getInternalInputFormat(org.apache.hadoop.conf.Configuration conf)
static java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>>	getInternalInputFormatClass(org.apache.hadoop.conf.Configuration conf)
static RecordInfoProvider<?,?>	getRecordInfoProvider(org.apache.hadoop.conf.Configuration conf)
static java.lang.Class<? extends RecordInfoProvider<?,?>>	getRecordInfoProviderClass(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	setInternalInputFormatClass(org.apache.hadoop.conf.Configuration conf, java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> iInputFormat)
static void	setRecordInfoProviderClass(org.apache.hadoop.conf.Configuration conf, java.lang.Class<? extends RecordInfoProvider<?,?>> provider)

Methods inherited from class org.apache.hadoop.mapreduce.InputFormat

createRecordReader

Methods inherited from class java.lang.Object

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

Field Detail

iInputFormat

protected org.apache.hadoop.mapreduce.InputFormat<?,?> iInputFormat

Constructor Detail

BaseWrapperInputFormat

public BaseWrapperInputFormat()

Method Detail

setInternalInputFormatClass

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

getInternalInputFormatClass

public static java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat<?,?>> getInternalInputFormatClass(org.apache.hadoop.conf.Configuration conf)

createInternalInputFormat

public static org.apache.hadoop.mapreduce.InputFormat<?,?> createInternalInputFormat(org.apache.hadoop.conf.Configuration conf)

getInternalInputFormat

public org.apache.hadoop.mapreduce.InputFormat<?,?> getInternalInputFormat(org.apache.hadoop.conf.Configuration conf)

setRecordInfoProviderClass

public static void setRecordInfoProviderClass(org.apache.hadoop.conf.Configuration conf,
                                              java.lang.Class<? extends RecordInfoProvider<?,?>> provider)

getRecordInfoProviderClass

public static java.lang.Class<? extends RecordInfoProvider<?,?>> getRecordInfoProviderClass(org.apache.hadoop.conf.Configuration conf)

getRecordInfoProvider

public static RecordInfoProvider<?,?> getRecordInfoProvider(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,
                                                                        java.lang.InterruptedException

Specified by:

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

Throws:

java.io.IOException

java.lang.InterruptedException

createRecordInfoProvider

public static RecordInfoProvider<?,?> createRecordInfoProvider(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass,
                                                               org.apache.hadoop.conf.Configuration conf)