protected static class EsPigInputFormat.PigShardRecordReader extends EsInputFormat.ShardRecordReader<java.lang.String,java.util.Map>
Constructor and Description |
---|
EsPigInputFormat.PigShardRecordReader() |
EsPigInputFormat.PigShardRecordReader(InputSplit split,
Configuration job,
Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
createKey() |
java.util.Map |
createValue() |
protected java.lang.String |
setCurrentKey(java.lang.String oldApiKey,
java.lang.String newApiKey,
java.lang.Object object) |
protected java.util.Map |
setCurrentValue(java.util.Map oldApiValue,
java.util.Map newApiKey,
java.lang.Object object) |
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue
public EsPigInputFormat.PigShardRecordReader()
public EsPigInputFormat.PigShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
public java.lang.String createKey()
createKey
in interface RecordReader<java.lang.String,java.util.Map>
createKey
in class EsInputFormat.ShardRecordReader<java.lang.String,java.util.Map>
public java.util.Map createValue()
createValue
in interface RecordReader<java.lang.String,java.util.Map>
createValue
in class EsInputFormat.ShardRecordReader<java.lang.String,java.util.Map>
protected java.lang.String setCurrentKey(java.lang.String oldApiKey, java.lang.String newApiKey, java.lang.Object object)
setCurrentKey
in class EsInputFormat.ShardRecordReader<java.lang.String,java.util.Map>
protected java.util.Map setCurrentValue(java.util.Map oldApiValue, java.util.Map newApiKey, java.lang.Object object)
setCurrentValue
in class EsInputFormat.ShardRecordReader<java.lang.String,java.util.Map>