Package org.elasticsearch.hadoop.mr
Class EsInputFormat.WritableEsInputRecordReader
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<K,V>
org.elasticsearch.hadoop.mr.EsInputFormat.EsInputRecordReader<Text,V>
org.elasticsearch.hadoop.mr.EsInputFormat.AbstractWritableEsInputRecordReader<Map<Writable,Writable>>
org.elasticsearch.hadoop.mr.EsInputFormat.WritableEsInputRecordReader
- All Implemented Interfaces:
Closeable,AutoCloseable,RecordReader<Text,Map<Writable, Writable>>
- Enclosing class:
- EsInputFormat<K,
V>
protected static class EsInputFormat.WritableEsInputRecordReader
extends EsInputFormat.AbstractWritableEsInputRecordReader<Map<Writable,Writable>>
-
Constructor Summary
ConstructorsConstructorDescriptionWritableEsInputRecordReader(InputSplit split, Configuration job, Reporter reporter) -
Method Summary
Methods inherited from class org.elasticsearch.hadoop.mr.EsInputFormat.AbstractWritableEsInputRecordReader
createKey, setCurrentKeyMethods inherited from class org.elasticsearch.hadoop.mr.EsInputFormat.EsInputRecordReader
close, getCurrentKey, getCurrentValue, getPos, getProgress, initialize, next, nextKeyValue
-
Constructor Details
-
WritableEsInputRecordReader
public WritableEsInputRecordReader() -
WritableEsInputRecordReader
-
-
Method Details
-
createValue
- Specified by:
createValuein interfaceRecordReader<Text,Map<Writable, Writable>> - Specified by:
createValuein classEsInputFormat.EsInputRecordReader<Text,Map<Writable, Writable>>
-
setCurrentValue
Description copied from class:EsInputFormat.EsInputRecordReaderSets the current value.- Specified by:
setCurrentValuein classEsInputFormat.EsInputRecordReader<Text,Map<Writable, Writable>> - Parameters:
hadoopValue- hadoop valueobject- the actual value to read- Returns:
- returns the value to be used; needed in scenario where the passed value is immutable
-