alluxio.client.file.cache.store

Class ByteArrayTargetBuffer

java.lang.Object

alluxio.client.file.cache.store.ByteArrayTargetBuffer

All Implemented Interfaces:

PageReadTargetBuffer

public class ByteArrayTargetBuffer
extends Object
implements PageReadTargetBuffer

Target buffer backed by bytes array for zero-copy read from page store.

Constructor Summary

Constructors

Constructor and Description
ByteArrayTargetBuffer(byte[] target, int offset) 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

ByteArrayTargetBuffer

public ByteArrayTargetBuffer(byte[] target,
                             int offset)

Constructor.

Parameters:

target -

offset -

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

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

byteChannel

public WritableByteChannel byteChannel()

Specified by:

byteChannel in interface PageReadTargetBuffer

Returns:

the writable channel