tachyon.worker

Class BlockHandlerLocal

java.lang.Object

tachyon.worker.BlockHandler

tachyon.worker.BlockHandlerLocal

All Implemented Interfaces:

Closeable, AutoCloseable

public final class BlockHandlerLocal
extends BlockHandler

BlockHandler for files on LocalFS, such as RamDisk, SSD and HDD.

Method Summary

Methods

Modifier and Type	Method and Description
int	append(long offset, ByteBuffer buf) Appends data to the block from a ByteBuffer
void	close()
boolean	delete() Deletes the block
ByteChannel	getChannel() Gets channel used to access block
long	getLength() Gets the length of the block
ByteBuffer	read(long offset, int length) Reads data from block

Methods inherited from class tachyon.worker.BlockHandler

append, get

Methods inherited from class java.lang.Object

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

Method Detail

append

public int append(long offset,
         ByteBuffer buf)
           throws IOException

Description copied from class: BlockHandler

Appends data to the block from a ByteBuffer

Specified by:

append in class BlockHandler

Parameters:

offset - starting position of the block file

buf - ByteBuffer that data is stored in

Returns:

the size of data that was written

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

delete

public boolean delete()
               throws IOException

Description copied from class: BlockHandler

Deletes the block

Specified by:

delete in class BlockHandler

Returns:

true if success, otherwise false

Throws:

IOException

getChannel

public ByteChannel getChannel()

Description copied from class: BlockHandler

Gets channel used to access block

Specified by:

getChannel in class BlockHandler

Returns:

the channel bounded with the block file

getLength

public long getLength()
               throws IOException

Description copied from class: BlockHandler

Gets the length of the block

Specified by:

getLength in class BlockHandler

Returns:

the length of the block

Throws:

IOException

read

public ByteBuffer read(long offset,
              int length)
                throws IOException

Description copied from class: BlockHandler

Reads data from block

Specified by:

read in class BlockHandler

Parameters:

offset - the offset from starting of the block file

length - the length of data to read, -1 represents reading the rest of the block

Returns:

ByteBuffer the data that was read

Throws:

IOException