org.apache.tez.runtime.library.common.sort.impl.dflt

Class DefaultSorter.MRResultIterator

java.lang.Object

org.apache.tez.runtime.library.common.sort.impl.dflt.DefaultSorter.MRResultIterator

All Implemented Interfaces:

TezRawKeyValueIterator

Enclosing class:

DefaultSorter

protected class DefaultSorter.MRResultIterator
extends Object
implements TezRawKeyValueIterator

Constructor Summary

Constructors

Constructor and Description
DefaultSorter.MRResultIterator(int start, int end)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the iterator so that the underlying streams can be closed.
org.apache.hadoop.io.DataInputBuffer	getKey() Gets the current raw key.
org.apache.hadoop.util.Progress	getProgress() Gets the Progress object; this has a float (0.0 - 1.0) indicating the bytes processed by the iterator so far
org.apache.hadoop.io.DataInputBuffer	getValue() Gets the current raw value.
boolean	next() Sets up the current key and value (for getKey and getValue).

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSorter.MRResultIterator

public DefaultSorter.MRResultIterator(int start,
                              int end)

Method Detail

next

public boolean next()
             throws IOException

Description copied from interface: TezRawKeyValueIterator

Sets up the current key and value (for getKey and getValue).

Specified by:

next in interface TezRawKeyValueIterator

Returns:

true if there exists a key/value, false otherwise.

Throws:

IOException

getKey

public org.apache.hadoop.io.DataInputBuffer getKey()
                                            throws IOException

Description copied from interface: TezRawKeyValueIterator

Gets the current raw key.

Specified by:

getKey in interface TezRawKeyValueIterator

Returns:

Gets the current raw key as a DataInputBuffer

Throws:

IOException

getValue

public org.apache.hadoop.io.DataInputBuffer getValue()
                                              throws IOException

Description copied from interface: TezRawKeyValueIterator

Gets the current raw value.

Specified by:

getValue in interface TezRawKeyValueIterator

Returns:

Gets the current raw value as a DataInputBuffer

Throws:

IOException

getProgress

public org.apache.hadoop.util.Progress getProgress()

Description copied from interface: TezRawKeyValueIterator

Gets the Progress object; this has a float (0.0 - 1.0) indicating the bytes processed by the iterator so far

Specified by:

getProgress in interface TezRawKeyValueIterator

close

public void close()

Description copied from interface: TezRawKeyValueIterator

Closes the iterator so that the underlying streams can be closed.

Specified by:

close in interface TezRawKeyValueIterator