alluxio.worker.block.io

Class LocalFileBlockWriter

java.lang.Object

alluxio.worker.block.io.BlockClient

alluxio.worker.block.io.BlockWriter

alluxio.worker.block.io.LocalFileBlockWriter

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

StoreBlockWriter

@NotThreadSafe
public class LocalFileBlockWriter
extends BlockWriter

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

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.worker.block.io.BlockClient

BlockClient.Type

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 alluxio.worker.block.io.BlockClient

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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 class: BlockWriter

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

Specified by:

append in class 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 class: BlockWriter

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

Specified by:

append in class 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 class: BlockWriter

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

Specified by:

append in class 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 class BlockWriter

Returns:

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

getChannel

public WritableByteChannel getChannel()

Specified by:

getChannel in class 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

Overrides:

close in class BlockClient

Throws:

IOException