Package | Description |
---|---|
alluxio.worker.netty |
Modifier and Type | Interface and Description |
---|---|
static interface |
AbstractReadHandler.PacketReader.Factory<T extends ReadRequest,P extends AbstractReadHandler.PacketReader<T>>
Factory that creates a PacketReader.
|
Modifier and Type | Class and Description |
---|---|
static class |
FileReadHandler.FilePacketReader
The packet reader to read from a local block worker.
|
Constructor and Description |
---|
AbstractReadHandler(ExecutorService executorService,
io.netty.channel.Channel channel,
Class<T> requestType,
AbstractReadHandler.PacketReader.Factory<T,? extends AbstractReadHandler.PacketReader<T>> packetReaderFactory)
Creates an instance of
AbstractReadHandler . |
NettyReadHandlerStateMachine(io.netty.channel.Channel channel,
Class<ReqT> requestType,
AbstractReadHandler.PacketReader.Factory<ReqT,? extends AbstractReadHandler.PacketReader<ReqT>> packetReaderFactory)
The state machine for reading packet task in Alluxio Worker.
|
Copyright © 2023. All Rights Reserved.