alluxio.worker.netty

Class FileReadHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

alluxio.worker.netty.AbstractReadHandler<BlockReadRequest>

alluxio.worker.netty.FileReadHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public class FileReadHandler
extends AbstractReadHandler<BlockReadRequest>

Handles file read request.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileReadHandler.FilePacketReader The packet reader to read from a local block worker.
static class	FileReadHandler.FilePacketReaderFactory Factory for creating FileReadHandler.FilePacketReaders.

Nested classes/interfaces inherited from class alluxio.worker.netty.AbstractReadHandler

AbstractReadHandler.PacketReader<T extends ReadRequest>

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
FileReadHandler(ExecutorService executorService, io.netty.channel.Channel channel, DoraWorker worker, FileTransferType fileTransferType) Creates an instance of FileReadHandler.

Method Summary

Modifier and Type	Method and Description
protected BlockReadRequest	createReadRequest(Protocol.ReadRequest request)
DoraWorker	getWorker() Gets worker.

Methods inherited from class alluxio.worker.netty.AbstractReadHandler

acceptMessage, channelRead, channelRegistered, channelUnregistered, exceptionCaught

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

FileReadHandler

public FileReadHandler(ExecutorService executorService,
                       io.netty.channel.Channel channel,
                       DoraWorker worker,
                       FileTransferType fileTransferType)

Creates an instance of FileReadHandler.

Parameters:

executorService - the executor service to run data readers

channel - the channel to which this handler is attached

worker - block worker

fileTransferType - the file transfer type

Method Detail

createReadRequest

protected BlockReadRequest createReadRequest(Protocol.ReadRequest request)

Specified by:

createReadRequest in class AbstractReadHandler<BlockReadRequest>

Parameters:

request - the block read request

Returns:

an instance of read request based on the request read from channel

getWorker

public DoraWorker getWorker()

Gets worker.

Returns:

dora worker