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