Package | Description |
---|---|
alluxio | |
alluxio.worker.block | |
alluxio.worker.block.io | |
alluxio.worker.block.meta |
Modifier and Type | Method and Description |
---|---|
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
DefaultStorageTierAssoc.intersectionList() |
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
DefaultStorageTierAssoc.intersectionList() |
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
StorageTierAssoc.intersectionList() |
List<Pair<BlockStoreLocation,BlockStoreLocation>> |
StorageTierAssoc.intersectionList() |
Modifier and Type | Method and Description |
---|---|
static BlockStoreLocation |
BlockStoreLocation.anyDirInAnyTierWithMedium(String mediumType)
Convenience method to return the block store location representing any dir in any tier
with specific medium.
|
static BlockStoreLocation |
BlockStoreLocation.anyDirInTier(String tierAlias)
Convenience method to return the block store location representing any dir in the tier.
|
static BlockStoreLocation |
BlockStoreLocation.anyTier()
Convenience method to return the block store location representing any dir in any tier.
|
BlockStoreLocation |
AllocateOptions.getLocation() |
Modifier and Type | Method and Description |
---|---|
Map<BlockStoreLocation,List<Long>> |
BlockHeartbeatReport.getAddedBlocks()
Gets the list of blocks added by the worker in the heartbeat this report represents.
|
Map<BlockStoreLocation,List<Long>> |
BlockStoreMeta.getBlockListByStorageLocation()
Note: This method is only available when users initialize
the blockStoreMeta with full block meta requirement.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BlockStoreLocation.belongsTo(BlockStoreLocation location)
Returns whether this location belongs to the specific location.
|
static AllocateOptions |
AllocateOptions.forCreate(long sizeBytes,
BlockStoreLocation location)
Creates default allocation options for block create request.
|
static AllocateOptions |
AllocateOptions.forMove(BlockStoreLocation location)
Creates default allocation options for moving a block by a client request.
|
static AllocateOptions |
AllocateOptions.forRequestSpace(long sizeBytes,
BlockStoreLocation location)
Creates default allocation options for requesting more space for a block.
|
static AllocateOptions |
AllocateOptions.forTierMove(BlockStoreLocation location)
Creates default allocation options for moving a block during tier-move task.
|
void |
BlockStoreEventListener.onAccessBlock(long blockId,
BlockStoreLocation location)
Actions when accessing a block.
|
void |
BlockStoreEventListener.onCommitBlockToLocal(long blockId,
BlockStoreLocation location)
Actions when committing a temporary block to a
BlockStoreLocation at local block store. |
void |
BlockStoreEventListener.onCommitBlockToMaster(long blockId,
BlockStoreLocation location)
Actions when a temporary block has been committed to the alluxio master.
|
void |
BlockStoreEventListener.onMoveBlockByClient(long blockId,
BlockStoreLocation oldLocation,
BlockStoreLocation newLocation)
Actions when moving a block by a client from a
BlockStoreLocation to another. |
void |
BlockStoreEventListener.onMoveBlockByWorker(long blockId,
BlockStoreLocation oldLocation,
BlockStoreLocation newLocation)
Actions when moving a block by a worker from a
BlockStoreLocation to another. |
void |
BlockStoreEventListener.onRemoveBlock(long blockId,
BlockStoreLocation location)
Actions when removing an existing block.
|
void |
BlockStoreEventListener.onStorageLost(BlockStoreLocation dirLocation)
Actions when a storage dir is lost.
|
AllocateOptions |
AllocateOptions.setLocation(BlockStoreLocation location)
Sets the allocation location.
|
Modifier and Type | Method and Description |
---|---|
List<LocationBlockIdListEntry> |
BlockMasterClient.convertBlockListMapToProto(Map<BlockStoreLocation,List<Long>> blockListOnLocation)
Converts the block list map to a proto list.
|
Command |
BlockMasterClient.heartbeat(long workerId,
Map<String,Long> capacityBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlocks,
Map<BlockStoreLocation,List<Long>> addedBlocks,
Map<String,List<String>> lostStorage,
List<Metric> metrics)
The method the worker should periodically execute to heartbeat back to the master.
|
void |
BlockMasterClient.register(long workerId,
List<String> storageTierAliases,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
Map<String,List<String>> lostStorage,
List<ConfigProperty> configList)
The method the worker should execute to register with the block master.
|
void |
BlockMasterClient.registerWithStream(long workerId,
List<String> storageTierAliases,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
Map<String,List<String>> lostStorage,
List<ConfigProperty> configList)
Registers with the master in a stream.
|
Constructor and Description |
---|
BlockHeartbeatReport(Map<BlockStoreLocation,List<Long>> addedBlocks,
List<Long> removedBlocks,
Map<String,List<String>> lostStorage)
Creates a new instance of
BlockHeartbeatReport . |
BlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap)
Constructor.
|
BlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap,
AlluxioConfiguration conf)
Constructor.
|
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
long workerId,
List<String> storageTierAliases,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
Map<String,List<String>> lostStorage,
List<ConfigProperty> configList)
Constructor.
|
RegisterStreamer(BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceStub asyncClient,
long workerId,
List<String> storageTierAliases,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<BlockStoreLocation,List<Long>> currentBlocksOnLocation,
Map<String,List<String>> lostStorage,
List<ConfigProperty> configList,
BuildVersion version)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockClientListener.clientClosed(BlockClient blockClient,
BlockStoreLocation location)
Called when an open block client is closed.
|
void |
BlockClientListener.clientOpened(BlockClient blockClient,
BlockStoreLocation location)
Called when a new block client is opened.
|
Modifier and Type | Method and Description |
---|---|
BlockStoreLocation |
TempBlockMeta.getBlockLocation() |
BlockStoreLocation |
BlockMeta.getBlockLocation() |
BlockStoreLocation |
StorageDir.toBlockStoreLocation() |
Copyright © 2023. All Rights Reserved.