org.elasticsearch.hadoop.pig
Class EsPigInputFormat.PigShardRecordReader
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<K,V>
org.elasticsearch.hadoop.mr.EsInputFormat.ShardRecordReader<String,Map>
org.elasticsearch.hadoop.pig.EsPigInputFormat.PigShardRecordReader
- All Implemented Interfaces:
- Closeable, RecordReader<String,Map>
- Enclosing class:
- EsPigInputFormat
protected static class EsPigInputFormat.PigShardRecordReader
- extends EsInputFormat.ShardRecordReader<String,Map>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EsPigInputFormat.PigShardRecordReader
public EsPigInputFormat.PigShardRecordReader()
EsPigInputFormat.PigShardRecordReader
public EsPigInputFormat.PigShardRecordReader(InputSplit split,
Configuration job,
Reporter reporter)
createKey
public String createKey()
- Specified by:
createKey
in interface RecordReader<String,Map>
- Specified by:
createKey
in class EsInputFormat.ShardRecordReader<String,Map>
createValue
public Map createValue()
- Specified by:
createValue
in interface RecordReader<String,Map>
- Specified by:
createValue
in class EsInputFormat.ShardRecordReader<String,Map>
setCurrentKey
protected String setCurrentKey(String oldApiKey,
String newApiKey,
Object object)
- Specified by:
setCurrentKey
in class EsInputFormat.ShardRecordReader<String,Map>
setCurrentValue
protected Map setCurrentValue(Map oldApiValue,
Map newApiKey,
Object object)
- Specified by:
setCurrentValue
in class EsInputFormat.ShardRecordReader<String,Map>