oracle.spatial.hadoop.vector.mapreduce.input

Class BaseWrapperInputFormat<K,V>

java.lang.Object

<any>

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

Direct Known Subclasses:

InputSplitInputFormat, JGeometryKeyInputFormat

public abstract class BaseWrapperInputFormat<K,V>
extends <any>

Constructor Summary

Constructors

Constructor and Description
BaseWrapperInputFormat()

Method Summary

Modifier and Type	Method and Description
static <any>	createInternalInputFormat(Configuration conf)
static RecordInfoProvider<?,?>	createRecordInfoProvider(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass, Configuration conf)
<any>	getInternalInputFormat(Configuration conf)
static java.lang.Class<? extends <any>>	getInternalInputFormatClass(Configuration conf)
static RecordInfoProvider<?,?>	getRecordInfoProvider(Configuration conf)
static java.lang.Class<? extends RecordInfoProvider<?,?>>	getRecordInfoProviderClass(Configuration conf)
java.util.List<InputSplit>	getSplits(JobContext context)
static <K,V> void	setInternalInputFormatClass(Configuration conf, java.lang.Class<? extends <any>> iInputFormat)
static void	setRecordInfoProviderClass(Configuration conf, java.lang.Class<? extends RecordInfoProvider<?,?>> provider)

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseWrapperInputFormat

public BaseWrapperInputFormat()

Method Detail

createInternalInputFormat

public static <any> createInternalInputFormat(Configuration conf)

createRecordInfoProvider

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

getInternalInputFormat

public <any> getInternalInputFormat(Configuration conf)

getInternalInputFormatClass

public static java.lang.Class<? extends <any>> getInternalInputFormatClass(Configuration conf)

getRecordInfoProvider

public static RecordInfoProvider<?,?> getRecordInfoProvider(Configuration conf)

getRecordInfoProviderClass

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

getSplits

public java.util.List<InputSplit> getSplits(JobContext context)
                                     throws java.io.IOException,
                                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

setInternalInputFormatClass

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

setRecordInfoProviderClass

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