alluxio.file

Class NettyBufTargetBuffer

java.lang.Object

alluxio.file.NettyBufTargetBuffer

All Implemented Interfaces:

ReadTargetBuffer

public class NettyBufTargetBuffer
extends Object
implements ReadTargetBuffer

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()
io.netty.buffer.ByteBuf	getTargetBuffer() Get the internal Bytebuf object.
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

NettyBufTargetBuffer

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

Parameters:

target - target buffer

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

getTargetBuffer

public io.netty.buffer.ByteBuf getTargetBuffer()

Get the internal Bytebuf object.

Returns:

the internal Bytebuf object