protected static class EsPigInputFormat.PigJsonShardRecordReader extends EsPigInputFormat.AbstractPigShardRecordReader<String>
Constructor and Description |
---|
EsPigInputFormat.PigJsonShardRecordReader() |
EsPigInputFormat.PigJsonShardRecordReader(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, setCurrentKey
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue
public EsPigInputFormat.PigJsonShardRecordReader()
public EsPigInputFormat.PigJsonShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
public String createValue()
createValue
in interface RecordReader<String,String>
createValue
in class EsInputFormat.ShardRecordReader<String,String>
protected String setCurrentValue(String hadoopValue, Object object)
EsInputFormat.ShardRecordReader
setCurrentValue
in class EsInputFormat.ShardRecordReader<String,String>
hadoopValue
- hadoop valueobject
- the actual value to read