tachyon.client

Class BlockInStream

java.lang.Object

java.io.InputStream

tachyon.client.InStream

tachyon.client.BlockInStream

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

LocalBlockInStream, RemoteBlockInStream

public abstract class BlockInStream
extends InStream

InputStream interface implementation of TachyonFile. It can only be gotten by calling the methods in tachyon.client.TachyonFile, but can not be initialized by the client code.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	mBlockIndex
protected boolean	mClosed

Fields inherited from class tachyon.client.InStream

mFile, mReadType, mTachyonFS

Method Summary

Methods

Modifier and Type	Method and Description
static BlockInStream	get(TachyonFile tachyonFile, ReadType readType, int blockIndex) Get a new BlockInStream of the given block without under file system configuration.
static BlockInStream	get(TachyonFile tachyonFile, ReadType readType, int blockIndex, Object ufsConf) Get a new BlockInStream of the given block with the under file system configuration.

Methods inherited from class tachyon.client.InStream

close, read, read, read, seek, skip

Methods inherited from class java.io.InputStream

available, mark, markSupported, reset

Methods inherited from class java.lang.Object

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

Field Detail

mBlockIndex

protected final int mBlockIndex

mClosed

protected boolean mClosed

Method Detail

get

public static BlockInStream get(TachyonFile tachyonFile,
                ReadType readType,
                int blockIndex)
                         throws IOException

Get a new BlockInStream of the given block without under file system configuration. The block is decided by the tachyonFile and blockIndex

Parameters:

tachyonFile - the file the block belongs to

readType - the InStream's read type

blockIndex - the index of the block in the tachyonFile

Returns:

A new LocalBlockInStream or RemoteBlockInStream

Throws:

IOException

get

public static BlockInStream get(TachyonFile tachyonFile,
                ReadType readType,
                int blockIndex,
                Object ufsConf)
                         throws IOException

Get a new BlockInStream of the given block with the under file system configuration. The block is decided by the tachyonFile and blockIndex

Parameters:

tachyonFile - the file the block belongs to

readType - the InStream's read type

blockIndex - the index of the block in the tachyonFile

ufsConf - the under file system configuration

Returns:

A new LocalBlockInStream or RemoteBlockInStream

Throws:

IOException