alluxio.worker.dora

Class PagedFileWriter

java.lang.Object

alluxio.worker.block.io.BlockClient

alluxio.worker.block.io.BlockWriter

alluxio.worker.dora.PagedFileWriter

All Implemented Interfaces:

Closeable, AutoCloseable

public class PagedFileWriter
extends BlockWriter

A paged implementation of BlockWriter interface.

Nested Class Summary

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

BlockClient.Type

Method Summary

Modifier and Type	Method and Description
void	abort() Abort writing.
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	commitFile() Commit the file.
WritableByteChannel	getChannel()
long	getPosition()

Methods inherited from class alluxio.worker.block.io.BlockClient

close, toString

Methods inherited from class java.lang.Object

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

Method Detail

abort

public void abort()

Description copied from class: BlockWriter

Abort writing.

Specified by:

abort in class BlockWriter

commitFile

public void commitFile()

Description copied from class: BlockWriter

Commit the file.

Specified by:

commitFile in class BlockWriter

append

public long append(ByteBuffer inputBuf)

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

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