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

java.lang.Object
  org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader

All Implemented Interfaces:

org.apache.tez.runtime.api.Reader, KeyValuesReader

Enclosing class:

ConcatenatedMergedKeyValuesInput

public class ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader
extends Object
implements KeyValuesReader

Constructor Summary

ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader()

Method Summary

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

Moves to the next key/values(s) pair

Specified by:

next in interface 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 interface: KeyValuesReader

Returns the current key

Specified by:

getCurrentKey in interface KeyValuesReader

Returns:

the current key

Throws:

IOException

getCurrentValues

public Iterable<Object> getCurrentValues()
                                  throws IOException

Description copied from interface: KeyValuesReader

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

Specified by:

getCurrentValues in interface KeyValuesReader

Returns:

an Iterable view of the values associated with the current key

Throws:

IOException