alluxio.worker.block.io

Class BlockReadableChannel

java.lang.Object

alluxio.worker.block.io.BlockReadableChannel

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ReadableByteChannel

@ThreadSafe
public class BlockReadableChannel
extends Object
implements ReadableByteChannel

Readable channel implementation for BlockReaders.
The channel can be safely read from multiple threads. Its closed state is independent of that of the block reader that created it. Its internal position is shared with the block reader, that is, calling read(ByteBuffer) will advance the internal position of the block reader, and subsequent calls to BlockReader.transferTo(ByteBuf) will start from where the channel was left off.

Constructor Summary

Constructors

Constructor and Description
BlockReadableChannel(BlockReader reader) Creates a new channel from a block reader.

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isOpen()
int	read(ByteBuffer dst)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockReadableChannel

public BlockReadableChannel(BlockReader reader)

Creates a new channel from a block reader.

Parameters:

reader - reader

Method Detail

read

public int read(ByteBuffer dst)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Throws:

IOException