K
- the type of the keys generated by the internal input formatV
- the type of the values generated by the internal input format
public class SubSplitRecordReader<K,V>
extends java.lang.Object
This class takes a list of sub splits (smaller parts of a split ) and reads the splits records using an internal input format
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
MIN_SUBSPLIT_DISTANCE
The minimum distance (in bytes) between two sub splits to be read by different RecordReader instances.
|
Constructor and Description |
---|
SubSplitRecordReader(java.util.List<FileSplit> subSplits, <any> internalInputFormat, JobConf conf, Reporter reporter)
Creates a new instance with the given sub splits to be read and sets the internal input format used to read the split's records.
|
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 MIN_SUBSPLIT_DISTANCE
public SubSplitRecordReader(java.util.List<FileSplit> subSplits, <any> internalInputFormat, JobConf conf, Reporter reporter) throws java.io.IOException
subSplits
- a list of splits which are smaller parts of a splitinternalInputFormat
- the input format used to read the split's recordsconf
- the job configurationreporter
- a reporter instancejava.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public K createKey()
public V createValue()
public long getPos() throws java.io.IOException
java.io.IOException
public float getProgress() throws java.io.IOException
java.io.IOException
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.