@InterfaceAudience.Private @InterfaceStability.Unstable public class InMemoryReader extends IFile.Reader
IFile.InMemoryReader
to read map-outputs present in-memory.IFile.Reader.KeyState
buffer, bufferSize, bytesRead, currentKeyLength, currentValueLength, dataIn, eof, isCompressed, originalKeyLength, prevKeyLength, recNo
Constructor and Description |
---|
InMemoryReader(MergeManager merger,
InputAttemptIdentifier taskAttemptId,
byte[] data,
int start,
int length) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
getLength() |
long |
getPosition() |
void |
nextRawValue(org.apache.hadoop.io.DataInputBuffer value) |
protected void |
readKeyValueLength(DataInput dIn) |
IFile.Reader.KeyState |
readRawKey(org.apache.hadoop.io.DataInputBuffer key) |
void |
reset(int offset) |
disableChecksumValidation, isCompressedFlagEnabled, nextRawKey, positionToNextRecord, readToMemory, readValueLength
public InMemoryReader(MergeManager merger, InputAttemptIdentifier taskAttemptId, byte[] data, int start, int length) throws IOException
IOException
public void reset(int offset)
reset
in class IFile.Reader
public long getPosition() throws IOException
getPosition
in class IFile.Reader
IOException
public long getLength()
getLength
in class IFile.Reader
protected void readKeyValueLength(DataInput dIn) throws IOException
readKeyValueLength
in class IFile.Reader
IOException
public IFile.Reader.KeyState readRawKey(org.apache.hadoop.io.DataInputBuffer key) throws IOException
readRawKey
in class IFile.Reader
IOException
public void nextRawValue(org.apache.hadoop.io.DataInputBuffer value) throws IOException
nextRawValue
in class IFile.Reader
IOException
public void close()
close
in class IFile.Reader
Copyright © 2015 Apache Software Foundation. All rights reserved.