public class CombineFileRecordReaderWrapper<K,V> extends java.lang.Object implements RecordReader<K,V>
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
INDIVIDUAL_INPUT_FORMAT
property that indicates how individual input format is to be interpreted
|
Constructor and Description |
---|
CombineFileRecordReaderWrapper(CombineFileSplit split,
Configuration conf,
Reporter reporter,
java.lang.Integer idx) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
K |
createKey() |
V |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(K key,
V value) |
public static final java.lang.String INDIVIDUAL_INPUT_FORMAT
public CombineFileRecordReaderWrapper(CombineFileSplit split, Configuration conf, Reporter reporter, java.lang.Integer idx) throws java.lang.Exception
java.lang.Exception
public boolean next(K key, V value) throws java.io.IOException
next
in interface RecordReader<K,V>
java.io.IOException
public V createValue()
createValue
in interface RecordReader<K,V>
public long getPos() throws java.io.IOException
getPos
in interface RecordReader<K,V>
java.io.IOException
public void close() throws java.io.IOException
close
in interface RecordReader<K,V>
java.io.IOException
public float getProgress() throws java.io.IOException
getProgress
in interface RecordReader<K,V>
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.