cascading.flow.tez.util

Class SecondarySortKeyValuesReader

java.lang.Object

org.apache.tez.runtime.api.Reader

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

cascading.flow.tez.util.SecondarySortKeyValuesReader

public class SecondarySortKeyValuesReader
extends org.apache.tez.runtime.library.api.KeyValuesReader

Field Summary

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

completedProcessing

Constructor Summary

Constructors

Constructor and Description
SecondarySortKeyValuesReader(org.apache.tez.runtime.library.api.KeyValuesReader parent, Comparator<Tuple> groupComparator)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	advance()
Object	getCurrentKey()
Iterable<Object>	getCurrentValues()
boolean	next()

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

SecondarySortKeyValuesReader

public SecondarySortKeyValuesReader(org.apache.tez.runtime.library.api.KeyValuesReader parent,
                            Comparator<Tuple> groupComparator)

Method Detail

next

public boolean next()
             throws IOException

Specified by:

next in class org.apache.tez.runtime.library.api.KeyValuesReader

Throws:

IOException

advance

protected boolean advance()
                   throws IOException

Throws:

IOException

getCurrentKey

public Object getCurrentKey()
                     throws IOException

Specified by:

getCurrentKey in class org.apache.tez.runtime.library.api.KeyValuesReader

Throws:

IOException

getCurrentValues

public Iterable<Object> getCurrentValues()
                                  throws IOException

Specified by:

getCurrentValues in class org.apache.tez.runtime.library.api.KeyValuesReader

Throws:

IOException