Package org.elasticsearch.hadoop.mr
Class EsInputFormat.JsonWritableEsInputRecordReader
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<K,V>
org.elasticsearch.hadoop.mr.EsInputFormat.EsInputRecordReader<Text,V>
org.elasticsearch.hadoop.mr.EsInputFormat.AbstractWritableEsInputRecordReader<Text>
org.elasticsearch.hadoop.mr.EsInputFormat.JsonWritableEsInputRecordReader
- All Implemented Interfaces:
Closeable,AutoCloseable,RecordReader<Text,Text>
- Enclosing class:
- EsInputFormat<K,
V>
protected static class EsInputFormat.JsonWritableEsInputRecordReader
extends EsInputFormat.AbstractWritableEsInputRecordReader<Text>
-
Constructor Summary
ConstructorsConstructorDescriptionJsonWritableEsInputRecordReader(InputSplit split, Configuration job, Reporter reporter) -
Method Summary
Modifier and TypeMethodDescriptionprotected TextsetCurrentValue(Text hadoopValue, Object object) Sets the current value.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
-
JsonWritableEsInputRecordReader
public JsonWritableEsInputRecordReader() -
JsonWritableEsInputRecordReader
-
-
Method Details
-
createValue
- Specified by:
createValuein interfaceRecordReader<Text,Text> - Specified by:
createValuein classEsInputFormat.EsInputRecordReader<Text,Text>
-
setCurrentValue
Description copied from class:EsInputFormat.EsInputRecordReaderSets the current value.- Specified by:
setCurrentValuein classEsInputFormat.EsInputRecordReader<Text,Text> - 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
-