elasticsearch-hadoop-cascading

org.elasticsearch.hadoop.mr
Class EsInputFormat.WritableShardRecordReader

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader<K,V>
      extended by org.elasticsearch.hadoop.mr.EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>
          extended by org.elasticsearch.hadoop.mr.EsInputFormat.WritableShardRecordReader
All Implemented Interfaces:
Closeable, RecordReader<Text,Map<Writable,Writable>>
Enclosing class:
EsInputFormat<K,V>

protected static class EsInputFormat.WritableShardRecordReader
extends EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>


Constructor Summary
EsInputFormat.WritableShardRecordReader()
           
EsInputFormat.WritableShardRecordReader(InputSplit split, Configuration job, Reporter reporter)
           
 
Method Summary
 Text createKey()
           
 Map<Writable,Writable> createValue()
           
protected  Text setCurrentKey(Text oldApiKey, Text newApiKey, Object object)
           
protected  Map<Writable,Writable> setCurrentValue(Map<Writable,Writable> oldApiValue, Map<Writable,Writable> 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

EsInputFormat.WritableShardRecordReader

public EsInputFormat.WritableShardRecordReader()

EsInputFormat.WritableShardRecordReader

public EsInputFormat.WritableShardRecordReader(InputSplit split,
                                               Configuration job,
                                               Reporter reporter)
Method Detail

createKey

public Text createKey()
Specified by:
createKey in interface RecordReader<Text,Map<Writable,Writable>>
Specified by:
createKey in class EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>

createValue

public Map<Writable,Writable> createValue()
Specified by:
createValue in interface RecordReader<Text,Map<Writable,Writable>>
Specified by:
createValue in class EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>

setCurrentKey

protected Text setCurrentKey(Text oldApiKey,
                             Text newApiKey,
                             Object object)
Specified by:
setCurrentKey in class EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>

setCurrentValue

protected Map<Writable,Writable> setCurrentValue(Map<Writable,Writable> oldApiValue,
                                                 Map<Writable,Writable> newApiKey,
                                                 Object object)
Specified by:
setCurrentValue in class EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>

elasticsearch-hadoop-cascading