Package | Description |
---|---|
alluxio.web | |
alluxio.worker.block | |
alluxio.worker.grpc |
Constructor and Description |
---|
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 |
---|
AsyncBlockRemover(BlockWorker worker)
Constructor of AsyncBlockRemover.
|
AsyncBlockRemover(BlockWorker worker,
int threads,
BlockingQueue<Long> blocksToRemove,
Set<Long> removingBlocks)
Constructor of AsyncBlockRemover.
|
AsyncCacheRequestManager(ExecutorService service,
BlockWorker blockWorker,
FileSystemContext fsContext) |
PinListSync(BlockWorker blockWorker,
FileSystemMasterClient masterClient)
Creates a new instance of
PinListSync . |
Constructor and Description |
---|
BlockReadHandler(ExecutorService executorService,
BlockWorker blockWorker,
io.grpc.stub.StreamObserver<ReadResponse> responseObserver,
AuthenticatedUserInfo userInfo,
boolean domainSocketEnabled)
Creates an instance of
AbstractReadHandler . |
Copyright © 2023. All Rights Reserved.