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