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