alluxio.worker.page

Class NettyBufTargetBuffer

java.lang.Object

alluxio.worker.page.NettyBufTargetBuffer

All Implemented Interfaces:

PageReadTargetBuffer

public class NettyBufTargetBuffer
extends Object
implements PageReadTargetBuffer

Netty Buf backed target buffer for zero-copy read from page store.

Constructor Summary

Constructors

Constructor and Description
NettyBufTargetBuffer(io.netty.buffer.ByteBuf target)

Method Summary

Modifier and Type	Method and Description
byte[]	byteArray()
ByteBuffer	byteBuffer()
WritableByteChannel	byteChannel()
long	offset()
int	readFromFile(RandomAccessFile file, int length)
long	remaining()
void	writeBytes(byte[] srcArray, int srcOffset, int length)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyBufTargetBuffer

public NettyBufTargetBuffer(io.netty.buffer.ByteBuf target)

Parameters:

target - target buffer

Method Detail

byteArray

public byte[] byteArray()

Specified by:

byteArray in interface PageReadTargetBuffer

Returns:

the byte array

byteBuffer

public ByteBuffer byteBuffer()

Specified by:

byteBuffer in interface PageReadTargetBuffer

Returns:

the byte buffer

offset

public long offset()

Specified by:

offset in interface PageReadTargetBuffer

Returns:

offset in the buffer

byteChannel

public WritableByteChannel byteChannel()

Specified by:

byteChannel in interface PageReadTargetBuffer

Returns:

the writable channel

remaining

public long remaining()

Specified by:

remaining in interface PageReadTargetBuffer

Returns:

the remaining for this buffer

writeBytes

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

Specified by:

writeBytes in interface PageReadTargetBuffer

readFromFile

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

Specified by:

readFromFile in interface PageReadTargetBuffer

Returns:

bytes read from the file

Throws:

IOException