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 |
---|---|
Optional<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(ClientContext ctx,
BlockWorker blockWorker) |
static FileSystemContext |
FileSystemContext.create(ClientContext ctx,
BlockWorker blockWorker,
List<InetSocketAddress> masterAddresses) |
Constructor and Description |
---|
WorkerWebServer(InetSocketAddress webAddress,
WorkerProcess workerProcess,
BlockWorker blockWorker)
Creates a new instance of
WorkerWebServer . |
Modifier and Type | Class and Description |
---|---|
class |
AllMasterRegistrationBlockWorker
The class is responsible for managing all top level components of BlockWorker.
|
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 BlockSyncMasterGroup |
BlockSyncMasterGroup.Factory.createAllMasterSync(BlockWorker blockWorker)
Creates a block sync master group that heartbeats to all masters.
|
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.
|
BlockMasterSync(BlockWorker blockWorker,
AtomicReference<Long> workerId,
WorkerNetAddress workerAddress,
BlockMasterClientPool masterClientPool)
Creates a new instance of
BlockMasterSync . |
BlockSyncMasterGroup(List<InetSocketAddress> masterAddresses,
BlockWorker blockWorker)
Creates a block sync master group.
|
PinListSync(BlockWorker blockWorker,
FileSystemMasterClient masterClient)
Creates a new instance of
PinListSync . |
SpecificMasterBlockSync(BlockWorker blockWorker,
BlockMasterClient masterClient,
BlockHeartbeatReporter heartbeatReporter)
Creates a new instance of
SpecificMasterBlockSync . |
TestSpecificMasterBlockSync(BlockWorker blockWorker,
BlockMasterClient masterClient,
BlockHeartbeatReporter heartbeatReporter)
Creates a new instance of
SpecificMasterBlockSync . |
Copyright © 2023. All Rights Reserved.