protected static class EsInputFormat.JsonWritableShardRecordReader extends EsInputFormat.AbstractWritableShardRecordReader<Text>
| Constructor and Description |
|---|
JsonWritableShardRecordReader() |
JsonWritableShardRecordReader(InputSplit split,
Configuration job,
Reporter reporter) |
| Modifier and Type | Method and Description |
|---|---|
Text |
createValue() |
protected Text |
setCurrentValue(Text hadoopValue,
Object object)
Sets the current value.
|
createKey, setCurrentKeyclose, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValuepublic JsonWritableShardRecordReader()
public JsonWritableShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
public Text createValue()
createValue in interface RecordReader<Text,Text>createValue in class EsInputFormat.ShardRecordReader<Text,Text>protected Text setCurrentValue(Text hadoopValue, Object object)
EsInputFormat.ShardRecordReadersetCurrentValue in class EsInputFormat.ShardRecordReader<Text,Text>hadoopValue - hadoop valueobject - the actual value to read