oracle.spatial.hadoop.vector.mapred.input

Class BaseCompositeInputFormat<K,V>

java.lang.Object

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

All Implemented Interfaces:

AbstractCompositeInputFormat<K,V>, org.apache.hadoop.mapred.InputFormat<K,V>

Direct Known Subclasses:

InputSplitInputFormat, JGeometryKeyInputFormat, PointKeyInputFormat

public abstract class BaseCompositeInputFormat<K,V>
extends java.lang.Object
implements AbstractCompositeInputFormat<K,V>

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
BaseCompositeInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.mapred.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.mapred.InputFormat<?,?>	getInternalInputFormat(org.apache.hadoop.mapred.JobConf jobConf)
static java.lang.Class<? extends org.apache.hadoop.mapred.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)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf jobConf, int minSplits)
static <K,V> void	setInternalInputFormatClass(org.apache.hadoop.conf.Configuration conf, java.lang.Class<? extends org.apache.hadoop.mapred.InputFormat<?,?>> iInputFormat)
static void	setRecordInfoProviderClass(org.apache.hadoop.conf.Configuration conf, java.lang.Class<? extends RecordInfoProvider<?,?>> provider)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.mapred.InputFormat

getRecordReader

Field Detail

iInputFormat

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

Constructor Detail

BaseCompositeInputFormat

public BaseCompositeInputFormat()

Method Detail

setInternalInputFormatClass

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

getInternalInputFormatClass

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

createInternalInputFormat

public static org.apache.hadoop.mapred.InputFormat<?,?> createInternalInputFormat(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)

createRecordInfoProvider

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

getInternalInputFormat

public org.apache.hadoop.mapred.InputFormat<?,?> getInternalInputFormat(org.apache.hadoop.mapred.JobConf jobConf)

Specified by:

getInternalInputFormat in interface AbstractCompositeInputFormat<K,V>

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf jobConf,
                                                       int minSplits)
                                                throws java.io.IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<K,V>

Throws:

java.io.IOException