org.apache.tez.runtime.library.common.readers
Class ShuffledUnorderedKVReader<K,V>

java.lang.Object
  org.apache.tez.runtime.library.common.readers.ShuffledUnorderedKVReader<K,V>

All Implemented Interfaces:

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

public class ShuffledUnorderedKVReader<K,V>
extends Object
implements KeyValueReader

Constructor Summary

ShuffledUnorderedKVReader(ShuffleManager shuffleManager, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength, int ifileBufferSize, org.apache.tez.common.counters.TezCounter inputRecordCounter)

Method Summary

Object	getCurrentKey() Returns the current key
Object	getCurrentValue() Returns the current value
boolean	next() Moves to the next key/values(s) pair
IFile.Reader	openIFileReader(FetchedInput fetchedInput)

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffledUnorderedKVReader

public ShuffledUnorderedKVReader(ShuffleManager shuffleManager,
                                 org.apache.hadoop.conf.Configuration conf,
                                 org.apache.hadoop.io.compress.CompressionCodec codec,
                                 boolean ifileReadAhead,
                                 int ifileReadAheadLength,
                                 int ifileBufferSize,
                                 org.apache.tez.common.counters.TezCounter inputRecordCounter)
                          throws IOException

Throws:

IOException

Method Detail

next

public boolean next()
             throws IOException

Moves to the next key/values(s) pair

Specified by:

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

Returns the current key

Specified by:

getCurrentKey in interface KeyValueReader

Returns:

the current key

Throws:

IOException

getCurrentValue

public Object getCurrentValue()
                       throws IOException

Description copied from interface: KeyValueReader

Returns the current value

Specified by:

getCurrentValue in interface KeyValueReader

Returns:

the current value

Throws:

IOException

openIFileReader

public IFile.Reader openIFileReader(FetchedInput fetchedInput)
                             throws IOException

Throws:

IOException