alluxio.client.block.stream

Class BlockWorkerDataReader

java.lang.Object

alluxio.client.block.stream.BlockWorkerDataReader

All Implemented Interfaces:

DataReader, Closeable, AutoCloseable

@NotThreadSafe
public final class BlockWorkerDataReader
extends Object
implements DataReader

A data reader that reads from a worker in the same process of this client directly. This data reader is similar to read from local worker via GrpcDataReader except that all communication with the local worker is via internal method call instead of external RPC frameworks.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockWorkerDataReader.Factory Factory class to create BlockWorkerDataReaders.

Method Summary

Modifier and Type	Method and Description
void	close()
long	pos()
DataBuffer	readChunk() Reads a chunk.

Methods inherited from class java.lang.Object

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

Method Detail

readChunk

public DataBuffer readChunk()
                     throws IOException

Description copied from interface: DataReader

Reads a chunk. The caller needs to release the chunk.

Specified by:

readChunk in interface DataReader

Returns:

the data buffer or null if EOF is reached

Throws:

IOException

pos

public long pos()

Specified by:

pos in interface DataReader

Returns:

the current stream position

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException