alluxio.worker.block.io

Interface BlockWriter

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

LocalFileBlockWriter

public interface BlockWriter
extends Closeable

A writer interface to write or update a block stored in managed storage.

This class does not provide thread-safety.

Method Summary

Modifier and Type	Method and Description
long	append(io.netty.buffer.ByteBuf buf) Appends buf.readableBytes() bytes to the end of this block writer from the given buf.
long	append(ByteBuffer inputBuf) Appends data to the end of a block from an input ByteBuffer.
long	append(DataBuffer buffer) Appends buffer.readableBytes() bytes to the end of this block writer from the given buffer.
WritableByteChannel	getChannel()
long	getPosition()

Methods inherited from interface java.io.Closeable

close

Method Detail

append

long append(ByteBuffer inputBuf)
     throws IOException

Appends data to the end of a block from an input ByteBuffer.

Parameters:

inputBuf - ByteBuffer that input data is stored in

Returns:

the size of data that was appended in bytes

Throws:

IOException

append

long append(io.netty.buffer.ByteBuf buf)
     throws IOException

Appends buf.readableBytes() bytes to the end of this block writer from the given buf.

Parameters:

buf - the byte buffer that holds the data

Returns:

the size of data that was appended in bytes

Throws:

IOException

append

long append(DataBuffer buffer)
     throws IOException

Appends buffer.readableBytes() bytes to the end of this block writer from the given buffer.

Parameters:

buffer - the byte buffer that holds the data

Returns:

the size of data that was appended in bytes

Throws:

IOException

getPosition

long getPosition()

Returns:

the current write position (same as the number of bytes written)

getChannel

WritableByteChannel getChannel()

Returns:

a writeable byte channel of the block