alluxio.worker.netty

Class FileReadHandler.FilePacketReaderFactory

java.lang.Object

alluxio.worker.netty.FileReadHandler.FilePacketReaderFactory

All Implemented Interfaces:

AbstractReadHandler.PacketReader.Factory<BlockReadRequest,FileReadHandler.FilePacketReader>

Enclosing class:

FileReadHandler

public static final class FileReadHandler.FilePacketReaderFactory
extends Object
implements AbstractReadHandler.PacketReader.Factory<BlockReadRequest,FileReadHandler.FilePacketReader>

Factory for creating FileReadHandler.FilePacketReaders.

Constructor Summary

Constructors

Constructor and Description
FilePacketReaderFactory(DoraWorker doraWorker, FileTransferType transferType) Constructor.

Method Summary

Modifier and Type	Method and Description
FileReadHandler.FilePacketReader	create(BlockReadRequest readRequest) Creates a new packet reader.

Methods inherited from class java.lang.Object

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

Constructor Detail

FilePacketReaderFactory

public FilePacketReaderFactory(DoraWorker doraWorker,
                               FileTransferType transferType)

Constructor.

Parameters:

doraWorker - dora worker

transferType - transfer type

Method Detail

create

public FileReadHandler.FilePacketReader create(BlockReadRequest readRequest)
                                        throws IOException

Description copied from interface: AbstractReadHandler.PacketReader.Factory

Creates a new packet reader.

Specified by:

create in interface AbstractReadHandler.PacketReader.Factory<BlockReadRequest,FileReadHandler.FilePacketReader>

Parameters:

readRequest - the read request

Returns:

packet reader

Throws:

IOException - if IOException occurs