org.apache.tez.runtime.library.input

Class ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader

java.lang.Object

org.apache.tez.runtime.api.Reader

org.apache.tez.runtime.library.api.KeyValueReader

org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader

Enclosing class:

ConcatenatedMergedKeyValueInput

public class ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader
extends KeyValueReader

Field Summary

Fields inherited from class org.apache.tez.runtime.library.api.KeyValueReader

completedProcessing

Constructor Summary

Constructors

Constructor and Description
ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader()

Method Summary

Methods

Modifier and Type	Method and Description
Object	getCurrentKey() Returns the current key
Object	getCurrentValue() Returns the current value
boolean	next() Moves to the next key/values(s) pair

Methods inherited from class org.apache.tez.runtime.library.api.KeyValueReader

hasCompletedProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader

public ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader()

Method Detail

next

public boolean next()
             throws IOException

Description copied from class: KeyValueReader

Moves to the next key/values(s) pair

Specified by:

next in class KeyValueReader

Returns:

true if another key/value(s) pair exists, false if there are no more.

Throws:

IOException - if an error occurs

getCurrentKey

public Object getCurrentKey()
                     throws IOException

Description copied from class: KeyValueReader

Returns the current key

Specified by:

getCurrentKey in class KeyValueReader

Returns:

the current key

Throws:

IOException

getCurrentValue

public Object getCurrentValue()
                       throws IOException

Description copied from class: KeyValueReader

Returns the current value

Specified by:

getCurrentValue in class KeyValueReader

Returns:

the current value

Throws:

IOException