@InterfaceStability.Unstable @InterfaceAudience.Private public class UnorderedKVReader<K,V> extends KeyValueReader
Constructor and Description |
---|
UnorderedKVReader(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) |
Modifier and Type | Method and Description |
---|---|
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) |
public UnorderedKVReader(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
IOException
public boolean next() throws IOException
next
in class KeyValueReader
IOException
- if an error occurspublic Object getCurrentKey() throws IOException
KeyValueReader
getCurrentKey
in class KeyValueReader
IOException
public Object getCurrentValue() throws IOException
KeyValueReader
getCurrentValue
in class KeyValueReader
IOException
public IFile.Reader openIFileReader(FetchedInput fetchedInput) throws IOException
IOException
Copyright © 2015 Apache Software Foundation. All rights reserved.