protected abstract static class EsInputFormat.AbstractWritableEsInputRecordReader<V> extends EsInputFormat.EsInputRecordReader<Text,V>
| Constructor and Description |
|---|
AbstractWritableEsInputRecordReader() |
AbstractWritableEsInputRecordReader(InputSplit split,
Configuration job,
Reporter reporter) |
| Modifier and Type | Method and Description |
|---|---|
Text |
createKey() |
protected Text |
setCurrentKey(Text hadoopKey,
java.lang.Object object)
Sets the current key.
|
close, createValue, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue, setCurrentValuepublic AbstractWritableEsInputRecordReader()
public AbstractWritableEsInputRecordReader(InputSplit split, Configuration job, Reporter reporter)
public Text createKey()
createKey in interface RecordReader<Text,V>createKey in class EsInputFormat.EsInputRecordReader<Text,V>protected Text setCurrentKey(Text hadoopKey, java.lang.Object object)
EsInputFormat.EsInputRecordReadersetCurrentKey in class EsInputFormat.EsInputRecordReader<Text,V>hadoopKey - hadoop keyobject - the actual value to read