Package | Description |
---|---|
alluxio.worker.dora | |
alluxio.worker.grpc | |
alluxio.worker.netty | |
alluxio.worker.s3 |
Modifier and Type | Class and Description |
---|---|
class |
PagedDoraWorker
Page store based dora worker.
|
Constructor and Description |
---|
DoraWorkerClientServiceHandler(DoraWorker doraWorker)
Creates a new implementation of gRPC BlockWorker interface.
|
Modifier and Type | Method and Description |
---|---|
protected DoraWorker |
FileWriteHandler.getWorker() |
DoraWorker |
FileReadHandler.getWorker()
Gets worker.
|
Constructor and Description |
---|
BlockPacketWriter(BlockWriteRequestContext context,
io.netty.channel.Channel channel,
DoraWorker worker) |
FilePacketReaderFactory(DoraWorker doraWorker,
FileTransferType transferType)
Constructor.
|
FileReadHandler(ExecutorService executorService,
io.netty.channel.Channel channel,
DoraWorker worker,
FileTransferType fileTransferType)
Creates an instance of
FileReadHandler . |
FileWriteHandler(ExecutorService executorService,
DoraWorker doraWorker)
Creates an instance of
FileWriteHandler . |
NettyDataServer(InetSocketAddress nettyBindAddress,
InetSocketAddress s3BindAddress,
UfsManager ufsManager,
DoraWorker doraWorker)
Creates a new instance of
NettyDataServer . |
Modifier and Type | Method and Description |
---|---|
DoraWorker |
S3NettyHandler.getDoraWorker()
Get dora worker object.
|
Modifier and Type | Method and Description |
---|---|
static S3NettyHandler |
S3NettyHandler.createHandler(io.netty.channel.ChannelHandlerContext context,
io.netty.handler.codec.http.HttpRequest request,
FileSystem fileSystem,
DoraWorker doraWorker,
AsyncUserAccessAuditLogWriter asyncAuditLogWriter)
Create a S3Handler based on the incoming Request.
|
Constructor and Description |
---|
S3HttpHandler(FileSystem fileSystem,
DoraWorker doraWorker,
AsyncUserAccessAuditLogWriter asyncAuditLogWriter,
ThreadPoolExecutor lightPool,
ThreadPoolExecutor heavyPool)
Constructs an instance of
S3HttpHandler . |
S3HttpPipelineHandler(FileSystem fileSystem,
DoraWorker doraWorker)
Constructs an instance of
S3HttpPipelineHandler . |
S3NettyHandler(String bucket,
String object,
io.netty.handler.codec.http.HttpRequest request,
io.netty.channel.ChannelHandlerContext ctx,
FileSystem fileSystem,
DoraWorker doraWorker,
AsyncUserAccessAuditLogWriter asyncAuditLogWriter)
Constructs an instance of
S3NettyHandler . |
Copyright © 2023. All Rights Reserved.