org.apache.tez.runtime.library.common.shuffle.impl
Class InMemoryReader

java.lang.Object
  org.apache.tez.runtime.library.common.sort.impl.IFile.Reader
      org.apache.tez.runtime.library.common.shuffle.impl.InMemoryReader

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class InMemoryReader
extends IFile.Reader

IFile.InMemoryReader to read map-outputs present in-memory.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tez.runtime.library.common.sort.impl.IFile.Reader

IFile.Reader.KeyState

Field Summary

Fields inherited from class org.apache.tez.runtime.library.common.sort.impl.IFile.Reader

buffer, bufferSize, bytesRead, currentKeyLength, currentValueLength, dataIn, eof, fileLength, prevKeyLength, recNo

Constructor Summary

InMemoryReader(MergeManager merger, InputAttemptIdentifier taskAttemptId, byte[] data, int start, int length)

Method Summary

void	close()
long	getLength()
long	getPosition()
void	nextRawValue(org.apache.hadoop.io.DataInputBuffer value)
IFile.Reader.KeyState	readRawKey(org.apache.hadoop.io.DataInputBuffer key)
void	reset(int offset)

Methods inherited from class org.apache.tez.runtime.library.common.sort.impl.IFile.Reader

disableChecksumValidation, nextRawKey, positionToNextRecord

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryReader

public InMemoryReader(MergeManager merger,
                      InputAttemptIdentifier taskAttemptId,
                      byte[] data,
                      int start,
                      int length)
               throws IOException

Throws:

IOException

Method Detail

reset

public void reset(int offset)

Overrides:

reset in class IFile.Reader

getPosition

public long getPosition()
                 throws IOException

Overrides:

getPosition in class IFile.Reader

Throws:

IOException

getLength

public long getLength()

Overrides:

getLength in class IFile.Reader

readRawKey

public IFile.Reader.KeyState readRawKey(org.apache.hadoop.io.DataInputBuffer key)
                                 throws IOException

Overrides:

readRawKey in class IFile.Reader

Throws:

IOException

nextRawValue

public void nextRawValue(org.apache.hadoop.io.DataInputBuffer value)
                  throws IOException

Overrides:

nextRawValue in class IFile.Reader

Throws:

IOException

close

public void close()

Overrides:

close in class IFile.Reader