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