Package | Description |
---|---|
alluxio.master.block | |
alluxio.master.meta | |
alluxio.master.table | |
alluxio.underfs |
Modifier and Type | Method and Description |
---|---|
void |
BlockMaster.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
String mediumType,
long blockId,
long length)
Marks a block as committed on a specific worker.
|
void |
DefaultBlockMaster.commitBlock(long workerId,
long usedBytesOnTier,
String tierAlias,
String mediumType,
long blockId,
long length) |
static WorkerRegisterContext |
WorkerRegisterContext.create(BlockMaster blockMaster,
long workerId,
io.grpc.stub.StreamObserver<RegisterWorkerPRequest> workerRequestObserver)
Creates a new
WorkerRegisterContext . |
MasterWorkerInfo |
BlockMaster.getWorker(long workerId)
Returns the internal
MasterWorkerInfo object to the caller. |
MasterWorkerInfo |
DefaultBlockMaster.getWorker(long workerId) |
void |
BlockMaster.removeDecommissionedWorker(long workerId)
Removes all associated metadata about the decommissioned worker from block master.
|
void |
DefaultBlockMaster.removeDecommissionedWorker(long workerId) |
void |
BlockMaster.workerRegister(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<Block.BlockLocation,List<Long>> currentBlocksOnLocation,
Map<String,StorageList> lostStorage,
RegisterWorkerPOptions options)
Updates metadata when a worker registers with the master.
|
void |
DefaultBlockMaster.workerRegister(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<Block.BlockLocation,List<Long>> currentBlocksOnLocation,
Map<String,StorageList> lostStorage,
RegisterWorkerPOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetaMaster.masterRegister(long masterId,
RegisterMasterPOptions options) |
void |
MetaMaster.masterRegister(long masterId,
RegisterMasterPOptions options)
A standby master registers with the leader master.
|
Modifier and Type | Method and Description |
---|---|
Table |
Database.getTable(String tableName) |
Modifier and Type | Method and Description |
---|---|
UfsManager.UfsClient |
JobUfsManager.get(long mountId) |
UfsManager.UfsClient |
WorkerUfsManager.get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
UfsManager.UfsClient |
AbstractUfsManager.get(long mountId) |
UfsManager.UfsClient |
UfsManager.get(long mountId)
Gets UFS information from the manager if this mount ID exists, or throws exception otherwise.
|
Copyright © 2023. All Rights Reserved.