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:

java.io.Closeable, java.lang.AutoCloseable, RecordReader<Text,Text>

Enclosing class:

EsInputFormat<K,V>

protected static class EsInputFormat.JsonWritableEsInputRecordReader
extends EsInputFormat.AbstractWritableEsInputRecordReader<Text>

Constructor Summary

Constructors

Constructor and Description
JsonWritableEsInputRecordReader()
JsonWritableEsInputRecordReader(InputSplit split, Configuration job, Reporter reporter)

Method Summary

Modifier and Type	Method and Description
Text	createValue()
protected Text	setCurrentValue(Text hadoopValue, java.lang.Object object) Sets the current value.

Methods inherited from class org.elasticsearch.hadoop.mr.EsInputFormat.AbstractWritableEsInputRecordReader

createKey, setCurrentKey

Methods inherited from class org.elasticsearch.hadoop.mr.EsInputFormat.EsInputRecordReader

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

JsonWritableEsInputRecordReader

public JsonWritableEsInputRecordReader()

JsonWritableEsInputRecordReader

public JsonWritableEsInputRecordReader(InputSplit split,
                                       Configuration job,
                                       Reporter reporter)

Method Detail

createValue

public Text createValue()

Specified by:

createValue in interface RecordReader<Text,Text>

Specified by:

createValue in class EsInputFormat.EsInputRecordReader<Text,Text>

setCurrentValue

protected Text setCurrentValue(Text hadoopValue,
                               java.lang.Object object)

Description copied from class: EsInputFormat.EsInputRecordReader

Sets the current value.

Specified by:

setCurrentValue in class EsInputFormat.EsInputRecordReader<Text,Text>

Parameters:

hadoopValue - hadoop value

object - the actual value to read

Returns:

returns the value to be used; needed in scenario where the passed value is immutable