|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.lib.CombineFileRecordReaderWrapper<K,V>
@InterfaceAudience.Public @InterfaceStability.Stable public abstract class CombineFileRecordReaderWrapper<K,V>
A wrapper class for a record reader that handles a single file split. It
delegates most of the methods to the wrapped instance. A concrete subclass
needs to provide a constructor that calls this parent constructor with the
appropriate input format. The subclass constructor must satisfy the specific
constructor signature that is required by
CombineFileRecordReader
.
Subclassing is needed to get a concrete record reader wrapper because of the
constructor requirement.
CombineFileRecordReader
,
CombineFileInputFormat
Constructor Summary | |
---|---|
protected |
CombineFileRecordReaderWrapper(FileInputFormat<K,V> inputFormat,
CombineFileSplit split,
Configuration conf,
Reporter reporter,
Integer idx)
|
Method Summary | |
---|---|
void |
close()
Close this InputSplit to future operations. |
K |
createKey()
Create an object of the appropriate type to be used as a key. |
V |
createValue()
Create an object of the appropriate type to be used as a value. |
long |
getPos()
Returns the current position in the input. |
float |
getProgress()
How much of the input has the RecordReader consumed i.e. |
boolean |
next(K key,
V value)
Reads the next key/value pair from the input for processing. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected CombineFileRecordReaderWrapper(FileInputFormat<K,V> inputFormat, CombineFileSplit split, Configuration conf, Reporter reporter, Integer idx) throws IOException
IOException
Method Detail |
---|
public boolean next(K key, V value) throws IOException
RecordReader
next
in interface RecordReader<K,V>
key
- the key to read data intovalue
- the value to read data into
IOException
public K createKey()
RecordReader
createKey
in interface RecordReader<K,V>
public V createValue()
RecordReader
createValue
in interface RecordReader<K,V>
public long getPos() throws IOException
RecordReader
getPos
in interface RecordReader<K,V>
IOException
public void close() throws IOException
RecordReader
InputSplit
to future operations.
close
in interface RecordReader<K,V>
IOException
public float getProgress() throws IOException
RecordReader
RecordReader
consumed i.e.
has been processed by?
getProgress
in interface RecordReader<K,V>
0.0
to 1.0
.
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |