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