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<java.util.Map<Writable,Writable>>

org.elasticsearch.hadoop.mr.EsInputFormat.WritableEsInputRecordReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, RecordReader<Text,java.util.Map<Writable,Writable>>

Enclosing class:

EsInputFormat<K,V>

protected static class EsInputFormat.WritableEsInputRecordReader
extends EsInputFormat.AbstractWritableEsInputRecordReader<java.util.Map<Writable,Writable>>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.util.Map<Writable,Writable>	createValue()
protected java.util.Map<Writable,Writable>	setCurrentValue(java.util.Map<Writable,Writable> 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

WritableEsInputRecordReader

public WritableEsInputRecordReader()

WritableEsInputRecordReader

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

Method Detail

createValue

public java.util.Map<Writable,Writable> createValue()

Specified by:

createValue in interface RecordReader<Text,java.util.Map<Writable,Writable>>

Specified by:

createValue in class EsInputFormat.EsInputRecordReader<Text,java.util.Map<Writable,Writable>>

setCurrentValue

protected java.util.Map<Writable,Writable> setCurrentValue(java.util.Map<Writable,Writable> hadoopValue,
                                                           java.lang.Object object)

Description copied from class: EsInputFormat.EsInputRecordReader

Sets the current value.

Specified by:

setCurrentValue in class EsInputFormat.EsInputRecordReader<Text,java.util.Map<Writable,Writable>>

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