org.elasticsearch.hadoop.mr
Class EsInputFormat.WritableShardRecordReader
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<K,V>
org.elasticsearch.hadoop.mr.EsInputFormat.ShardRecordReader<Text,Map<Writable,Writable>>
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>>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EsInputFormat.WritableShardRecordReader
public EsInputFormat.WritableShardRecordReader()
EsInputFormat.WritableShardRecordReader
public EsInputFormat.WritableShardRecordReader(InputSplit split,
Configuration job,
Reporter reporter)
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>>