Package | Description |
---|---|
alluxio.web | |
alluxio.worker.block | |
alluxio.worker.file | |
alluxio.worker.netty |
Constructor and Description |
---|
WebInterfaceWorkerBlockInfoServlet(BlockWorker blockWorker)
Creates a new instance of
WebInterfaceWorkerBlockInfoServlet . |
WebInterfaceWorkerGeneralServlet(BlockWorker blockWorker,
InetSocketAddress workerAddress,
long startTimeMs)
Creates a new instance of
WebInterfaceWorkerGeneralServlet . |
WorkerWebServer(InetSocketAddress webAddress,
WorkerProcess workerProcess,
BlockWorker blockWorker,
String connectHost,
long startTimeMs)
Creates a new instance of
WorkerWebServer . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultBlockWorker
The class is responsible for managing all top level components of the Block Worker.
|
Modifier and Type | Method and Description |
---|---|
BlockWorker |
BlockWorkerFactory.create(WorkerRegistry registry,
UfsManager ufsManager) |
Modifier and Type | Method and Description |
---|---|
static void |
DefaultBlockWorker.Metrics.registerGauges(BlockWorker blockWorker)
Registers metric gauges.
|
Constructor and Description |
---|
AsyncCacheRequestManager(ExecutorService service,
BlockWorker blockWorker) |
BlockWorkerClientServiceHandler(BlockWorker worker)
Creates a new instance of
BlockWorkerClientServiceHandler . |
PinListSync(BlockWorker blockWorker,
FileSystemMasterClient masterClient)
Creates a new instance of
PinListSync . |
SpaceReserver(BlockWorker blockWorker)
Creates a new instance of
SpaceReserver . |
Constructor and Description |
---|
FileDataManager(BlockWorker blockWorker,
com.google.common.util.concurrent.RateLimiter persistenceRateLimiter,
UfsManager ufsManager)
Creates a new instance of
FileDataManager . |
Constructor and Description |
---|
BlockPacketWriter(BlockWriteRequestContext context,
io.netty.channel.Channel channel,
BlockWorker worker) |
BlockReadHandler(ExecutorService executorService,
BlockWorker blockWorker,
alluxio.worker.netty.FileTransferType fileTransferType)
Creates an instance of
AbstractReadHandler . |
Copyright © 2023. All Rights Reserved.