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