tachyon.client

Class BlockOutStream

java.lang.Object

java.io.OutputStream

tachyon.client.OutStream

tachyon.client.BlockOutStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class BlockOutStream
extends OutStream

BlockOutStream implementation of TachyonFile. This class is not client facing.

Field Summary

Fields inherited from class tachyon.client.OutStream

mFile, mTachyonFS, mUserConf, mWriteType

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Cancel the write operations to the OutStream
boolean	canWrite()
void	close()
void	flush()
long	getBlockId()
long	getBlockOffset()
long	getRemainingSpaceByte()
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.lang.Object

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

Method Detail

cancel

public void cancel()
            throws IOException

Description copied from class: OutStream

Cancel the write operations to the OutStream

Specified by:

cancel in class OutStream

Throws:

IOException

canWrite

public boolean canWrite()

Returns:

true if the stream can write and is not closed, otherwise false

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class OutStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Specified by:

flush in class OutStream

Throws:

IOException

getBlockId

public long getBlockId()

Returns:

the block id of the block

getBlockOffset

public long getBlockOffset()

Returns:

the block offset in the file.

getRemainingSpaceByte

public long getRemainingSpaceByte()

Returns:

the remaining space of the block, in bytes

write

public void write(byte[] b)
           throws IOException

Specified by:

write in class OutStream

Throws:

IOException

write

public void write(byte[] b,
         int off,
         int len)
           throws IOException

Specified by:

write in class OutStream

Throws:

IOException

write

public void write(int b)
           throws IOException

Specified by:

write in class OutStream

Throws:

IOException