Package | Description |
---|---|
alluxio.web | |
alluxio.worker.block | |
alluxio.worker.file | |
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.
|
AsyncCacheRequestManager(ExecutorService service,
BlockWorker blockWorker,
FileSystemContext fsContext) |
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 |
---|
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.