oracle.spatial.hadoop.vector.mapred.input

Class MultipleInputsInputFormat

java.lang.Object

oracle.spatial.hadoop.vector.mapred.input.MultipleInputsInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

public class MultipleInputsInputFormat
extends java.lang.Object
implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MultipleInputsInputFormat.MultipleInputsRecordReader

Constructor Summary

Constructors

Constructor and Description
MultipleInputsInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,RecordInfo>	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf jobConf, int minSplits)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipleInputsInputFormat

public MultipleInputsInputFormat()

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,RecordInfo> getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                                                                   org.apache.hadoop.mapred.JobConf jobConf,
                                                                                                   org.apache.hadoop.mapred.Reporter reporter)
                                                                                            throws java.io.IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

Throws:

java.io.IOException

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<org.apache.hadoop.io.Text,RecordInfo>

Throws:

java.io.IOException