public class CombineFileRecordReaderWrapper<K,V> extends Object implements RecordReader<K,V>
Modifier and Type | Field and Description |
---|---|
static 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,
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 String INDIVIDUAL_INPUT_FORMAT
public CombineFileRecordReaderWrapper(CombineFileSplit split, Configuration conf, Reporter reporter, Integer idx) throws Exception
Exception
public boolean next(K key, V value) throws IOException
next
in interface RecordReader<K,V>
IOException
public V createValue()
createValue
in interface RecordReader<K,V>
public long getPos() throws IOException
getPos
in interface RecordReader<K,V>
IOException
public void close() throws IOException
close
in interface RecordReader<K,V>
IOException
public float getProgress() throws IOException
getProgress
in interface RecordReader<K,V>
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.