alluxio.worker.netty

Interface AbstractReadHandler.PacketReader<T extends ReadRequest>

Type Parameters:

T - type of read request

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

FileReadHandler.FilePacketReader

Enclosing class:

AbstractReadHandler<T extends ReadRequest>

public static interface AbstractReadHandler.PacketReader<T extends ReadRequest>
extends Closeable

A runnable that reads packets and writes them to the channel.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	AbstractReadHandler.PacketReader.Factory<T extends ReadRequest,P extends AbstractReadHandler.PacketReader<T>> Factory that creates a PacketReader.

Method Summary

Modifier and Type	Method and Description
DataBuffer	getDataBuffer(io.netty.channel.Channel channel, long offset, int len) Returns the appropriate DataBuffer representing the data to send, depending on the configurable transfer type.

Methods inherited from interface java.io.Closeable

close

Method Detail

getDataBuffer

DataBuffer getDataBuffer(io.netty.channel.Channel channel,
                         long offset,
                         int len)
                  throws Exception

Returns the appropriate DataBuffer representing the data to send, depending on the configurable transfer type.

Parameters:

channel - the netty channel

offset - offset

len - The length, in bytes, of the data to read from the block

Returns:

a DataBuffer representing the data

Throws:

Exception