org.apache.hadoop.mapred.nativetask.buffer

Class InputBuffer

java.lang.Object

org.apache.hadoop.mapred.nativetask.buffer.InputBuffer

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.Private
public class InputBuffer
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor and Description
InputBuffer(BufferType type, int inputSize)
InputBuffer(byte[] bytes)

Method Summary

Modifier and Type	Method and Description
byte[]	array()
int	capacity()
void	close()
ByteBuffer	getByteBuffer()
BufferType	getType()
int	length()
int	position()
int	position(int pos)
int	remaining()
void	rewind(int startOffset, int length)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputBuffer

public InputBuffer(BufferType type,
                   int inputSize)
            throws IOException

Throws:

IOException

InputBuffer

public InputBuffer(byte[] bytes)

Method Detail

getType

public BufferType getType()

getByteBuffer

public ByteBuffer getByteBuffer()

length

public int length()

rewind

public void rewind(int startOffset,
                   int length)

remaining

public int remaining()

position

public int position()

position

public int position(int pos)

capacity

public int capacity()

array

public byte[] array()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable