elasticsearch-hadoop-pig

org.elasticsearch.hadoop.pig
Class EsPigInputFormat.PigShardRecordReader

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader<K,V>
      extended by org.elasticsearch.hadoop.mr.EsInputFormat.ShardRecordReader<String,Map>
          extended by 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>


Constructor Summary
EsPigInputFormat.PigShardRecordReader()
           
EsPigInputFormat.PigShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
           
 
Method Summary
 String createKey()
           
 Map createValue()
           
protected  String setCurrentKey(String oldApiKey, String newApiKey, Object object)
           
protected  Map setCurrentValue(Map oldApiValue, Map newApiKey, Object object)
           
 
Methods inherited from class org.elasticsearch.hadoop.mr.EsInputFormat.ShardRecordReader
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

EsPigInputFormat.PigShardRecordReader

public EsPigInputFormat.PigShardRecordReader()

EsPigInputFormat.PigShardRecordReader

public EsPigInputFormat.PigShardRecordReader(InputSplit split,
                                             Configuration job,
                                             Reporter reporter)
Method Detail

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>

elasticsearch-hadoop-pig