alluxio.client.file.cache.store

Class ByteBufferTargetBuffer

java.lang.Object

alluxio.client.file.cache.store.ByteBufferTargetBuffer

All Implemented Interfaces:

PageReadTargetBuffer

public class ByteBufferTargetBuffer
extends Object
implements PageReadTargetBuffer

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()
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

ByteBufferTargetBuffer

public ByteBufferTargetBuffer(ByteBuffer target)

Constructor.

Parameters:

target -

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