alluxio.worker.block.io

Class StoreBlockReader

java.lang.Object

alluxio.worker.block.io.BlockClient

alluxio.worker.block.io.BlockReader

alluxio.worker.block.io.LocalFileBlockReader

alluxio.worker.block.io.StoreBlockReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class StoreBlockReader
extends LocalFileBlockReader

A local block reader used by block store. It provides integration with the BlockStreamTracker.

Nested Class Summary

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

BlockClient.Type

Constructor Summary

Constructors

Constructor and Description
StoreBlockReader(long sessionId, BlockMeta blockMeta) Creates new block reader for block store.

Method Summary

Modifier and Type	Method and Description
void	close()

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

decreaseUsageCount, getChannel, getFilePath, getLength, getLocation, getUsageCount, increaseUsageCount, isClosed, read, transferTo

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

StoreBlockReader

public StoreBlockReader(long sessionId,
                        BlockMeta blockMeta)
                 throws IOException

Creates new block reader for block store.

Parameters:

sessionId - session id

blockMeta - block meta

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class LocalFileBlockReader

Throws:

IOException