alluxio.client.block.stream

Class LocalFilePacketReader

java.lang.Object

alluxio.client.block.stream.LocalFilePacketReader

All Implemented Interfaces:

PacketReader, Closeable, AutoCloseable

@NotThreadSafe
public final class LocalFilePacketReader
extends Object
implements PacketReader

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LocalFilePacketReader.Factory Factory class to create LocalFilePacketReaders.

Method Summary

Modifier and Type	Method and Description
void	close()
long	pos()
DataBuffer	readPacket() Reads a packet.

Methods inherited from class java.lang.Object

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

Method Detail

readPacket

public DataBuffer readPacket()
                      throws IOException

Description copied from interface: PacketReader

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

Specified by:

readPacket in interface PacketReader

Returns:

the data buffer or null if EOF is reached

Throws:

IOException

pos

public long pos()

Specified by:

pos in interface PacketReader

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