org.apache.tez.runtime.library.input

Class ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader

java.lang.Object

org.apache.tez.runtime.api.Reader

org.apache.tez.runtime.library.api.KeyValuesReader

org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader

Enclosing class:

ConcatenatedMergedKeyValuesInput

public class ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader
extends KeyValuesReader

Field Summary

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

completedProcessing

Constructor Summary

Constructors

Constructor and Description
ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader()

Method Summary

Methods

Modifier and Type	Method and Description
Object	getCurrentKey() Returns the current key
Iterable<Object>	getCurrentValues() Returns an Iterable view of the values associated with the current key
boolean	next() Moves to the next key/values(s) pair

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

hasCompletedProcessing

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader

public ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader()

Method Detail

next

public boolean next()
             throws IOException

Description copied from class: KeyValuesReader

Moves to the next key/values(s) pair

Specified by:

next in class KeyValuesReader

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: KeyValuesReader

Returns the current key

Specified by:

getCurrentKey in class KeyValuesReader

Returns:

the current key

Throws:

IOException

getCurrentValues

public Iterable<Object> getCurrentValues()
                                  throws IOException

Description copied from class: KeyValuesReader

Returns an Iterable view of the values associated with the current key

Specified by:

getCurrentValues in class KeyValuesReader

Returns:

an Iterable view of the values associated with the current key

Throws:

IOException