Uses of Class
alluxio.worker.block.BlockStoreLocation

Packages that use BlockStoreLocation

Package	Description
alluxio
alluxio.stress
alluxio.stress.cli
alluxio.worker.block
alluxio.worker.block.allocator
alluxio.worker.block.annotator
alluxio.worker.block.evictor	Set of evictors for evicting or moving blocks to other locations.
alluxio.worker.block.io
alluxio.worker.block.management
alluxio.worker.block.meta
alluxio.worker.page

Uses of BlockStoreLocation in alluxio

Methods in alluxio that return types with arguments of type BlockStoreLocation

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()

Uses of BlockStoreLocation in alluxio.stress

Method parameters in alluxio.stress with type arguments of type BlockStoreLocation

Modifier and Type	Method and Description
List<LocationBlockIdListEntry>	CachingBlockMasterClient.convertBlockListMapToProto(Map<BlockStoreLocation,List<Long>> blockListOnLocation)
void	CachingBlockMasterClient.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)

Constructor parameters in alluxio.stress with type arguments of type BlockStoreLocation

Constructor and Description
CachingBlockMapIterator(Map<BlockStoreLocation,List<Long>> blockLocationMap, AlluxioConfiguration conf) Constructor.
CachingBlockMasterClient(MasterClientContext conf, Map<BlockStoreLocation,List<Long>> blockMap) Creates a new instance and caches the converted proto.

Uses of BlockStoreLocation in alluxio.stress.cli

Fields in alluxio.stress.cli declared as BlockStoreLocation

Modifier and Type	Field and Description
static BlockStoreLocation	RpcBenchPreparationUtils.BLOCK_LOCATION_MEM

Methods in alluxio.stress.cli that return types with arguments of type BlockStoreLocation

Modifier and Type	Method and Description
static Map<BlockStoreLocation,List<Long>>	RpcBenchPreparationUtils.generateBlockIdOnTiers(Map<TierAlias,List<Integer>> tiersConfig) Generates block IDs according to the storage tier/dir setup.

Method parameters in alluxio.stress.cli with type arguments of type BlockStoreLocation

Modifier and Type	Method and Description
static void	RpcBenchPreparationUtils.prepareBlocksInMaster(Map<BlockStoreLocation,List<Long>> locToBlocks) Prepare all relevant block IDs on the master side concurrently.

Uses of BlockStoreLocation in alluxio.worker.block

Methods in alluxio.worker.block that return BlockStoreLocation

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()

Methods in alluxio.worker.block that return types with arguments of type BlockStoreLocation

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>>	DefaultBlockStoreMeta.getBlockListByStorageLocation()
Map<BlockStoreLocation,List<Long>>	BlockStoreMeta.getBlockListByStorageLocation() Note: This method is only available when users initialize the blockStoreMeta with full block meta requirement.

Methods in alluxio.worker.block with parameters of type BlockStoreLocation

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	TieredBlockStore.freeSpace(long sessionId, long minContiguousBytes, long minAvailableBytes, BlockStoreLocation location) Free space is the entry for immediate block deletion in order to open up space for new or ongoing blocks.
long	BlockMetadataEvictorView.getAvailableBytes(BlockStoreLocation location) Gets available bytes given certain location BlockMetadataManager.getAvailableBytes(BlockStoreLocation).
long	BlockMetadataManager.getAvailableBytes(BlockStoreLocation location) Gets the amount of available space of given location in bytes.
StorageDir	BlockMetadataManager.getDir(BlockStoreLocation location) Gets the StorageDir given its location in the store.
List<StorageDirView>	BlockMetadataEvictorView.getDirs(BlockStoreLocation location) Gets all dir views that belongs to a given location.
void	AbstractBlockStoreEventListener.onAccessBlock(long blockId, BlockStoreLocation location)
void	BlockStoreEventListener.onAccessBlock(long blockId, BlockStoreLocation location) Actions when accessing a block.
void	AbstractBlockStoreEventListener.onCommitBlockToLocal(long blockId, BlockStoreLocation location)
void	BlockStoreEventListener.onCommitBlockToLocal(long blockId, BlockStoreLocation location) Actions when committing a temporary block to a BlockStoreLocation at local block store.
void	AbstractBlockStoreEventListener.onCommitBlockToMaster(long blockId, BlockStoreLocation location)
void	BlockStoreEventListener.onCommitBlockToMaster(long blockId, BlockStoreLocation location) Actions when a temporary block has been committed to the alluxio master.
void	BlockMetricsReporter.onMoveBlockByClient(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	AbstractBlockStoreEventListener.onMoveBlockByClient(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockHeartbeatReporter.onMoveBlockByClient(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockStoreEventListener.onMoveBlockByClient(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a client from a BlockStoreLocation to another.
void	BlockMetricsReporter.onMoveBlockByWorker(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	AbstractBlockStoreEventListener.onMoveBlockByWorker(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockHeartbeatReporter.onMoveBlockByWorker(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockStoreEventListener.onMoveBlockByWorker(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a worker from a BlockStoreLocation to another.
void	AbstractBlockStoreEventListener.onRemoveBlock(long blockId, BlockStoreLocation location)
void	BlockStoreEventListener.onRemoveBlock(long blockId, BlockStoreLocation location) Actions when removing an existing block.
void	AbstractBlockStoreEventListener.onStorageLost(BlockStoreLocation dirLocation)
void	BlockStoreEventListener.onStorageLost(BlockStoreLocation dirLocation) Actions when a storage dir is lost.
AllocateOptions	AllocateOptions.setLocation(BlockStoreLocation location) Sets the allocation location.

Method parameters in alluxio.worker.block with type arguments of type BlockStoreLocation

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 parameters in alluxio.worker.block with type arguments of type BlockStoreLocation

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.

Uses of BlockStoreLocation in alluxio.worker.block.allocator

Methods in alluxio.worker.block.allocator with parameters of type BlockStoreLocation

Modifier and Type	Method and Description
StorageDirView	GreedyAllocator.allocateBlockWithView(long blockSize, BlockStoreLocation location, BlockMetadataView metadataView, boolean skipReview)
StorageDirView	RoundRobinAllocator.allocateBlockWithView(long blockSize, BlockStoreLocation location, BlockMetadataView metadataView, boolean skipReview)
StorageDirView	MaxFreeAllocator.allocateBlockWithView(long blockSize, BlockStoreLocation location, BlockMetadataView metadataView, boolean skipReview)
StorageDirView	Allocator.allocateBlockWithView(long blockSize, BlockStoreLocation location, BlockMetadataView view, boolean skipReview) Allocates a block from the given block store location under a given view.

Uses of BlockStoreLocation in alluxio.worker.block.annotator

Methods in alluxio.worker.block.annotator with parameters of type BlockStoreLocation

Modifier and Type	Method and Description
boolean	EmulatingBlockIterator.aligned(BlockStoreLocation srcLocation, BlockStoreLocation dstLocation, BlockOrder order, java.util.function.Function<Long,Boolean> blockFilterFunc)
boolean	DefaultBlockIterator.aligned(BlockStoreLocation srcLocation, BlockStoreLocation dstLocation, BlockOrder order, java.util.function.Function<Long,Boolean> blockFilterFunc)
boolean	BlockIterator.aligned(BlockStoreLocation srcLocation, BlockStoreLocation dstLocation, BlockOrder order, java.util.function.Function<Long,Boolean> blockFilterFunc) Used to detect presence of an overlap between two locations.
List<Long>	EmulatingBlockIterator.getIntersectionList(BlockStoreLocation srcLocation, BlockOrder srcOrder, BlockStoreLocation dstLocation, BlockOrder dstOrder, int intersectionWidth, BlockOrder intersectionOrder, java.util.function.Function<Long,Boolean> blockFilterFunc)
List<Long>	DefaultBlockIterator.getIntersectionList(BlockStoreLocation srcLocation, BlockOrder srcOrder, BlockStoreLocation dstLocation, BlockOrder dstOrder, int intersectionWidth, BlockOrder intersectionOrder, java.util.function.Function<Long,Boolean> blockFilterFunc)
List<Long>	BlockIterator.getIntersectionList(BlockStoreLocation srcLocation, BlockOrder srcOrder, BlockStoreLocation dstLocation, BlockOrder dstOrder, int intersectionWidth, BlockOrder intersectionOrder, java.util.function.Function<Long,Boolean> blockFilterFunc) Used to get blocks within an intersection of locations in sorted order.
Iterator<Long>	EmulatingBlockIterator.getIterator(BlockStoreLocation location, BlockOrder order)
Iterator<Long>	DefaultBlockIterator.getIterator(BlockStoreLocation location, BlockOrder order)
Iterator<Long>	BlockIterator.getIterator(BlockStoreLocation location, BlockOrder order) Gets an iterator of block-Ids.
Pair<List<Long>,List<Long>>	EmulatingBlockIterator.getSwaps(BlockStoreLocation srcLocation, BlockOrder srcOrder, BlockStoreLocation dstLocation, BlockOrder dstOrder, int swapRange, BlockOrder intersectionOrder, java.util.function.Function<Long,Boolean> blockFilterFunc)
Pair<List<Long>,List<Long>>	DefaultBlockIterator.getSwaps(BlockStoreLocation srcLocation, BlockOrder srcOrder, BlockStoreLocation dstLocation, BlockOrder dstOrder, int swapRange, BlockOrder intersectionOrder, java.util.function.Function<Long,Boolean> blockFilterFunc)
Pair<List<Long>,List<Long>>	BlockIterator.getSwaps(BlockStoreLocation srcLocation, BlockOrder srcOrder, BlockStoreLocation dstLocation, BlockOrder dstOrder, int swapRange, BlockOrder intersectionOrder, java.util.function.Function<Long,Boolean> blockFilterFunc) Used to list of blocks, that if swapped, could eliminate overlap between two tiers.

Uses of BlockStoreLocation in alluxio.worker.block.evictor

Methods in alluxio.worker.block.evictor that return BlockStoreLocation

Modifier and Type	Method and Description
BlockStoreLocation	BlockTransferInfo.getDstLocation()
BlockStoreLocation	BlockTransferInfo.getSrcLocation()

Methods in alluxio.worker.block.evictor that return types with arguments of type BlockStoreLocation

Modifier and Type	Method and Description
List<Pair<Long,BlockStoreLocation>>	EvictionPlan.toEvict()

Methods in alluxio.worker.block.evictor with parameters of type BlockStoreLocation

Modifier and Type	Method and Description
protected StorageDirEvictorView	AbstractEvictor.cascadingEvict(long bytesToBeAvailable, BlockStoreLocation location, EvictionPlan plan, Evictor.Mode mode) Deprecated. A recursive implementation of cascading eviction.
static BlockTransferInfo	BlockTransferInfo.createMove(BlockStoreLocation srcLocation, long srcBlockId, BlockStoreLocation dstLocation) Creates a new instance of BlockTransferInfo for moving a block.
static BlockTransferInfo	BlockTransferInfo.createSwap(BlockStoreLocation srcLocation, long srcBlockId, BlockStoreLocation dstLocation, long dstBlockId) Creates a new instance of BlockTransferInfo for swapping two blocks.
EvictionPlan	Evictor.freeSpaceWithView(long availableBytes, BlockStoreLocation location, BlockMetadataEvictorView view) Frees space with the guaranteed mode.
EvictionPlan	AbstractEvictor.freeSpaceWithView(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView view) Deprecated.
EvictionPlan	Evictor.freeSpaceWithView(long availableBytes, BlockStoreLocation location, BlockMetadataEvictorView view, Evictor.Mode mode) Frees space in the given block store location and with the given view.
EvictionPlan	AbstractEvictor.freeSpaceWithView(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView view, Evictor.Mode mode) Deprecated.
void	LRUEvictor.onCommitBlockToLocal(long blockId, BlockStoreLocation location) Deprecated.

Constructor parameters in alluxio.worker.block.evictor with type arguments of type BlockStoreLocation

Constructor and Description
EvictionPlan(List<BlockTransferInfo> toTransfer, List<Pair<Long,BlockStoreLocation>> toEvict) Creates a new instance of EvictionPlan.

Uses of BlockStoreLocation in alluxio.worker.block.io

Methods in alluxio.worker.block.io with parameters of type BlockStoreLocation

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.
static void	BlockStreamTracker.readerClosed(BlockReader reader, BlockStoreLocation location) Called when an existing block reader is closed.
static void	BlockStreamTracker.readerOpened(BlockReader reader, BlockStoreLocation location) Called with a new block reader.
static void	BlockStreamTracker.writerClosed(BlockWriter writer, BlockStoreLocation location) Called when an existing block writer is closed.
static void	BlockStreamTracker.writerOpened(BlockWriter writer, BlockStoreLocation location) Called with a new block writer.

Uses of BlockStoreLocation in alluxio.worker.block.management

Methods in alluxio.worker.block.management with parameters of type BlockStoreLocation

Modifier and Type	Method and Description
void	DefaultStoreLoadTracker.clientClosed(BlockClient blockClient, BlockStoreLocation location)
void	DefaultStoreLoadTracker.clientOpened(BlockClient blockClient, BlockStoreLocation location)
boolean	DefaultStoreLoadTracker.loadDetected(BlockStoreLocation... locations)
boolean	StoreLoadTracker.loadDetected(BlockStoreLocation... locations) Used to detect load on particular location.

Uses of BlockStoreLocation in alluxio.worker.block.meta

Methods in alluxio.worker.block.meta that return BlockStoreLocation

Modifier and Type	Method and Description
BlockStoreLocation	DefaultTempBlockMeta.getBlockLocation()
BlockStoreLocation	DefaultBlockMeta.getBlockLocation()
BlockStoreLocation	BlockMeta.getBlockLocation()
BlockStoreLocation	TempBlockMeta.getBlockLocation()
BlockStoreLocation	DefaultStorageDir.toBlockStoreLocation()
BlockStoreLocation	StorageDirView.toBlockStoreLocation() Creates a BlockStoreLocation for this directory view.
BlockStoreLocation	StorageDir.toBlockStoreLocation()

Uses of BlockStoreLocation in alluxio.worker.page

Fields in alluxio.worker.page declared as BlockStoreLocation

Modifier and Type	Field and Description
protected BlockStoreLocation	PagedBlockStoreDir.mLocation

Methods in alluxio.worker.page that return BlockStoreLocation

Modifier and Type	Method and Description
BlockStoreLocation	PagedBlockMeta.getBlockLocation()
BlockStoreLocation	PagedBlockStoreDir.getLocation()

Methods in alluxio.worker.page that return types with arguments of type BlockStoreLocation

Modifier and Type	Method and Description
Map<BlockStoreLocation,List<Long>>	PagedBlockStoreMeta.getBlockListByStorageLocation()