alluxio.client.block.stream

Interface PacketReader

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

LocalFilePacketReader, NettyPacketReader

public interface PacketReader
extends Closeable

The interface to read packets.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PacketReader.Factory The factory interface to create PacketReaders.

Method Summary

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

Methods inherited from interface java.io.Closeable

close

Method Detail

readPacket

DataBuffer readPacket()
               throws IOException

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

Returns:

the data buffer or null if EOF is reached

Throws:

IOException

pos

long pos()

Returns:

the current stream position