alluxio.file

Class ByteBufferTargetBuffer

java.lang.Object

alluxio.file.ByteBufferTargetBuffer

All Implemented Interfaces:

ReadTargetBuffer

public class ByteBufferTargetBuffer
extends Object
implements ReadTargetBuffer

Target buffer backed by nio ByteBuffer for zero-copy read from page store.

Constructor Summary

Constructors

Constructor and Description
ByteBufferTargetBuffer(ByteBuffer target) Constructor.

Method Summary

Modifier and Type	Method and Description
byte[]	byteArray()
ByteBuffer	byteBuffer()
WritableByteChannel	byteChannel()
int	offset()
void	offset(int newOffset) Sets the new offset in the buffer.
int	readFromFile(RandomAccessFile file, int length)
int	readFromInputStream(InputStream is, int length)
long	remaining()
void	writeBytes(byte[] srcArray, int srcOffset, int length)
void	writeBytes(io.netty.buffer.ByteBuf buf)

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteBufferTargetBuffer

public ByteBufferTargetBuffer(ByteBuffer target)

Constructor.

Parameters:

target -

Method Detail

byteArray

public byte[] byteArray()

Specified by:

byteArray in interface ReadTargetBuffer

Returns:

the byte array

byteBuffer

public ByteBuffer byteBuffer()

Specified by:

byteBuffer in interface ReadTargetBuffer

Returns:

the byte buffer

offset

public int offset()

Specified by:

offset in interface ReadTargetBuffer

Returns:

offset in the buffer

offset

public void offset(int newOffset)

Description copied from interface: ReadTargetBuffer

Sets the new offset in the buffer.

Specified by:

offset in interface ReadTargetBuffer

Parameters:

newOffset - the new offset

byteChannel

public WritableByteChannel byteChannel()

Specified by:

byteChannel in interface ReadTargetBuffer

Returns:

the writable channel

remaining

public long remaining()

Specified by:

remaining in interface ReadTargetBuffer

Returns:

the remaining for this buffer

writeBytes

public void writeBytes(byte[] srcArray,
                       int srcOffset,
                       int length)

Specified by:

writeBytes in interface ReadTargetBuffer

writeBytes

public void writeBytes(io.netty.buffer.ByteBuf buf)

Specified by:

writeBytes in interface ReadTargetBuffer

readFromFile

public int readFromFile(RandomAccessFile file,
                        int length)
                 throws IOException

Specified by:

readFromFile in interface ReadTargetBuffer

Returns:

bytes read from the file

Throws:

IOException

readFromInputStream

public int readFromInputStream(InputStream is,
                               int length)
                        throws IOException

Specified by:

readFromInputStream in interface ReadTargetBuffer

Returns:

bytes read from input stream

Throws:

IOException