alluxio.client.block.stream

Class LocalFileDataReader

java.lang.Object

alluxio.client.block.stream.LocalFileDataReader

All Implemented Interfaces:

DataReader, java.io.Closeable, java.lang.AutoCloseable

@NotThreadSafe
public final class LocalFileDataReader
extends java.lang.Object
implements DataReader

A data reader that simply reads packets from a local file.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LocalFileDataReader.Factory Factory class to create LocalFileDataReaders.

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 java.io.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:

java.io.IOException

pos

public long pos()

Specified by:

pos in interface DataReader

Returns:

the current stream position

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException