org.elasticsearch.hadoop.mr

Class EsInputFormat.EsInputRecordReader<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<K,V>

org.elasticsearch.hadoop.mr.EsInputFormat.EsInputRecordReader<K,V>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, RecordReader<K,V>

Direct Known Subclasses:

EsInputFormat.AbstractWritableEsInputRecordReader

Enclosing class:

EsInputFormat<K,V>

protected abstract static class EsInputFormat.EsInputRecordReader<K,V>
extends RecordReader<K,V>
implements RecordReader<K,V>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
abstract K	createKey()
abstract V	createValue()
K	getCurrentKey()
V	getCurrentValue()
long	getPos()
float	getProgress()
void	initialize(InputSplit split, TaskAttemptContext context)
boolean	next(K key, V value)
boolean	nextKeyValue()
protected abstract K	setCurrentKey(K hadoopKey, java.lang.Object object) Sets the current key.
protected abstract V	setCurrentValue(V hadoopValue, java.lang.Object object) Sets the current value.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EsInputRecordReader

public EsInputRecordReader()

EsInputRecordReader

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

Method Detail

initialize

public void initialize(InputSplit split,
                       TaskAttemptContext context)
                throws java.io.IOException

Specified by:

initialize in class RecordReader<K,V>

Throws:

java.io.IOException

nextKeyValue

public boolean nextKeyValue()
                     throws java.io.IOException

Specified by:

nextKeyValue in class RecordReader<K,V>

Throws:

java.io.IOException

getCurrentKey

public K getCurrentKey()
                throws java.io.IOException

Specified by:

getCurrentKey in class RecordReader<K,V>

Throws:

java.io.IOException

getCurrentValue

public V getCurrentValue()

Specified by:

getCurrentValue in class RecordReader<K,V>

getProgress

public float getProgress()

Specified by:

getProgress in interface RecordReader<K,V>

Specified by:

getProgress in class RecordReader<K,V>

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface RecordReader<K,V>

Specified by:

close in class RecordReader<K,V>

Throws:

java.io.IOException

next

public boolean next(K key,
                    V value)
             throws java.io.IOException

Specified by:

next in interface RecordReader<K,V>

Throws:

java.io.IOException

createKey

public abstract K createKey()

Specified by:

createKey in interface RecordReader<K,V>

createValue

public abstract V createValue()

Specified by:

createValue in interface RecordReader<K,V>

setCurrentKey

protected abstract K setCurrentKey(K hadoopKey,
                                   java.lang.Object object)

Sets the current key.

Parameters:

hadoopKey - hadoop key

object - the actual value to read

Returns:

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

setCurrentValue

protected abstract V setCurrentValue(V hadoopValue,
                                     java.lang.Object object)

Sets the current value.

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

getPos

public long getPos()

Specified by:

getPos in interface RecordReader<K,V>