public class DirectInMemoryReader<K,V>
extends org.apache.hadoop.mapred.IFile.Reader<K,V>
Constructor and Description |
---|
DirectInMemoryReader(DirectShuffleMergeManagerImpl<K,V> merger,
org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId,
byte[] data,
int start,
int length,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
getLength() |
long |
getPosition() |
boolean |
nextRawKey(org.apache.hadoop.io.DataInputBuffer key) |
void |
nextRawValue(org.apache.hadoop.io.DataInputBuffer value) |
void |
reset(int offset) |
public DirectInMemoryReader(DirectShuffleMergeManagerImpl<K,V> merger, org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptId, byte[] data, int start, int length, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public void reset(int offset)
public long getPosition() throws IOException
getPosition
in class org.apache.hadoop.mapred.IFile.Reader<K,V>
IOException
public long getLength()
public boolean nextRawKey(org.apache.hadoop.io.DataInputBuffer key) throws IOException
nextRawKey
in class org.apache.hadoop.mapred.IFile.Reader<K,V>
IOException
public void nextRawValue(org.apache.hadoop.io.DataInputBuffer value) throws IOException
nextRawValue
in class org.apache.hadoop.mapred.IFile.Reader<K,V>
IOException
Copyright © 2018 Apache Software Foundation. All Rights Reserved.