protected abstract static class EsInputFormat.ShardRecordReader<K,V> extends RecordReader<K,V> implements RecordReader<K,V>
| Constructor and Description |
|---|
EsInputFormat.ShardRecordReader() |
EsInputFormat.ShardRecordReader(InputSplit split,
Configuration job,
Reporter reporter) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
abstract K |
createKey() |
abstract V |
createValue() |
K |
getCurrentKey() |
V |
getCurrentValue() |
long |
getPos() |
float |
getProgress() |
void |
initialize(InputSplit split,
TaskAttemptContext context) |
boolean |
next(K key,
V value) |
boolean |
nextKeyValue() |
protected abstract K |
setCurrentKey(K hadoopKey,
Object object)
Sets the current key.
|
protected abstract V |
setCurrentValue(V hadoopValue,
Object object)
Sets the current value.
|
public EsInputFormat.ShardRecordReader()
public EsInputFormat.ShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
public void initialize(InputSplit split, TaskAttemptContext context) throws IOException
initialize in class RecordReader<K,V>IOExceptionpublic boolean nextKeyValue()
throws IOException
nextKeyValue in class RecordReader<K,V>IOExceptionpublic K getCurrentKey() throws IOException
getCurrentKey in class RecordReader<K,V>IOExceptionpublic V getCurrentValue()
getCurrentValue in class RecordReader<K,V>public float getProgress()
getProgress in interface RecordReader<K,V>getProgress in class RecordReader<K,V>public void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in interface RecordReader<K,V>close in class RecordReader<K,V>IOExceptionpublic boolean next(K key, V value) throws IOException
next in interface RecordReader<K,V>IOExceptionpublic abstract K createKey()
createKey in interface RecordReader<K,V>public abstract V createValue()
createValue in interface RecordReader<K,V>protected abstract K setCurrentKey(K hadoopKey, Object object)
hadoopKey - hadoop keyobject - the actual value to readprotected abstract V setCurrentValue(V hadoopValue, Object object)
hadoopValue - hadoop valueobject - the actual value to readpublic long getPos()
getPos in interface RecordReader<K,V>