Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.client.file | |
alluxio.web | |
alluxio.worker.block |
Constructor and Description |
---|
Factory(BlockWorker blockWorker,
long blockId,
long chunkSize,
InStreamOptions options)
Creates an instance of
BlockWorkerDataReader.Factory . |
Modifier and Type | Method and Description |
---|---|
BlockWorker |
FileSystemContext.getProcessLocalWorker()
Acquires the internal block worker as a gateway for worker internal clients to communicate
with the local worker directly without going through external RPC frameworks.
|
Modifier and Type | Method and Description |
---|---|
static FileSystemContext |
FileSystemContext.create(Subject subject,
AlluxioConfiguration conf,
BlockWorker blockWorker) |
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.
|
CacheRequestManager(ExecutorService service,
BlockWorker blockWorker,
FileSystemContext fsContext) |
PinListSync(BlockWorker blockWorker,
FileSystemMasterClient masterClient)
Creates a new instance of
PinListSync . |
Copyright © 2023. All Rights Reserved.