alluxio.client.block.stream

Interface DataReader

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Implementing Classes:

BlockWorkerDataReader, GrpcDataReader, LocalFileDataReader, SharedGrpcDataReader

public interface DataReader
extends java.io.Closeable

The interface to read data chunks.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	DataReader.Factory The factory interface to create DataReaders.

Method Summary

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

Methods inherited from interface java.io.Closeable

close

Method Detail

readChunk

DataBuffer readChunk()
              throws java.io.IOException

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

Returns:

the data buffer or null if EOF is reached

Throws:

java.io.IOException

pos

long pos()

Returns:

the current stream position