alluxio.worker.block.io

Class LocalFileBlockWriter

java.lang.Object

alluxio.worker.block.io.LocalFileBlockWriter

All Implemented Interfaces:

BlockWriter, Closeable, AutoCloseable

@NotThreadSafe
public final class LocalFileBlockWriter
extends Object
implements BlockWriter

This class provides write access to a temp block data file locally stored in managed storage.

Constructor Summary

Constructors

Constructor and Description
LocalFileBlockWriter(String path) Constructs a Block writer given the file path of the block.

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.
void	close()
WritableByteChannel	getChannel()
long	getPosition()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalFileBlockWriter

public LocalFileBlockWriter(String path)
                     throws IOException

Constructs a Block writer given the file path of the block.

Parameters:

path - file path of the block

Throws:

IOException

Method Detail

append

public long append(ByteBuffer inputBuf)
            throws IOException

Description copied from interface: BlockWriter

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

Specified by:

append in interface BlockWriter

Parameters:

inputBuf - ByteBuffer that input data is stored in

Returns:

the size of data that was appended in bytes

Throws:

IOException

append

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

Description copied from interface: BlockWriter

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

Specified by:

append in interface BlockWriter

Parameters:

buf - the byte buffer that holds the data

Returns:

the size of data that was appended in bytes

Throws:

IOException

append

public long append(DataBuffer buffer)
            throws IOException

Description copied from interface: BlockWriter

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

Specified by:

append in interface BlockWriter

Parameters:

buffer - the byte buffer that holds the data

Returns:

the size of data that was appended in bytes

Throws:

IOException

getPosition

public long getPosition()

Specified by:

getPosition in interface BlockWriter

Returns:

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

getChannel

public WritableByteChannel getChannel()

Specified by:

getChannel in interface BlockWriter

Returns:

a writeable byte channel of the block

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException