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