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 oldApiKey,
String newApiKey,
Object object) |
protected Map |
setCurrentValue(Map oldApiValue,
Map newApiKey,
Object object) |
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue
public 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 oldApiKey, String newApiKey, Object object)
setCurrentKey
in class EsInputFormat.ShardRecordReader<String,Map>
protected Map setCurrentValue(Map oldApiValue, Map newApiKey, Object object)
setCurrentValue
in class EsInputFormat.ShardRecordReader<String,Map>