Uses of Class
alluxio.worker.block.BlockStoreLocation

Packages that use BlockStoreLocation

Package	Description
alluxio.worker.block
alluxio.worker.block.allocator
alluxio.worker.block.evictor	Set of evictors for evicting or moving blocks to other locations.
alluxio.worker.block.meta

Uses of BlockStoreLocation in alluxio.worker.block

Methods in alluxio.worker.block that return BlockStoreLocation

Modifier and Type	Method and Description
static BlockStoreLocation	BlockStoreLocation.anyDirInTier(String tierAlias) Convenience method to return the block store location representing any dir in the tier.
static BlockStoreLocation	BlockStoreLocation.anyDirInTierWithMedium(String mediumType) Convenience method to return the block store location representing any dir in any tier with specific medium.
static BlockStoreLocation	BlockStoreLocation.anyTier() Convenience method to return the block store location representing any dir in any tier.

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 is only available in BlockStoreMeta.Factory.createFull(alluxio.worker.block.BlockMetadataManager).

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.
TempBlockMeta	TieredBlockStore.createBlock(long sessionId, long blockId, BlockStoreLocation location, long initialBlockSize)
TempBlockMeta	BlockStore.createBlock(long sessionId, long blockId, BlockStoreLocation location, long initialBlockSize) Creates the metadata of a new block and assigns a temporary path (e.g., a subdir of the final location named after session id) to store its data.
void	TieredBlockStore.freeSpace(long sessionId, long availableBytes, BlockStoreLocation location)
void	BlockStore.freeSpace(long sessionId, long availableBytes, BlockStoreLocation location) Frees space to make a specific amount of bytes available in a best-effort way in the location.
long	BlockMetadataManager.getAvailableBytes(BlockStoreLocation location) Gets the amount of available space of given location in bytes.
long	BlockMetadataEvictorView.getAvailableBytes(BlockStoreLocation location) Gets available bytes given certain location BlockMetadataManager.getAvailableBytes(BlockStoreLocation).
String	BlockMetadataManager.getBlockPath(long blockId, BlockStoreLocation location) Returns the path of a block given its location, or null if the location is not a specific StorageDir.
StorageDir	BlockMetadataManager.getDir(BlockStoreLocation location) Gets the StorageDir given its location in the store.
void	TieredBlockStore.moveBlock(long sessionId, long blockId, BlockStoreLocation newLocation)
void	BlockStore.moveBlock(long sessionId, long blockId, BlockStoreLocation newLocation) Moves an existing block to a new location.
void	TieredBlockStore.moveBlock(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockStore.moveBlock(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Moves an existing block to a new location.
BlockMeta	BlockMetadataManager.moveBlockMeta(BlockMeta blockMeta, BlockStoreLocation newLocation) Deprecated. As of version 0.8. Use BlockMetadataManager.moveBlockMeta(BlockMeta, TempBlockMeta) instead.
void	AbstractBlockStoreEventListener.onCommitBlock(long sessionId, long blockId, BlockStoreLocation location)
void	BlockStoreEventListener.onCommitBlock(long sessionId, long blockId, BlockStoreLocation location) Actions when committing a temporary block to a BlockStoreLocation.
void	BlockMetricsReporter.onMoveBlockByClient(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	AbstractBlockStoreEventListener.onMoveBlockByClient(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockHeartbeatReporter.onMoveBlockByClient(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockStoreEventListener.onMoveBlockByClient(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a client from a BlockStoreLocation to another.
void	BlockMetricsReporter.onMoveBlockByWorker(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	AbstractBlockStoreEventListener.onMoveBlockByWorker(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockHeartbeatReporter.onMoveBlockByWorker(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation)
void	BlockStoreEventListener.onMoveBlockByWorker(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a worker from a BlockStoreLocation to another.
void	TieredBlockStore.removeBlock(long sessionId, long blockId, BlockStoreLocation location)
void	BlockStore.removeBlock(long sessionId, long blockId, BlockStoreLocation location) Removes an existing block.

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

Modifier and Type	Method and Description
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.

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.

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	MaxFreeAllocator.allocateBlockWithView(long sessionId, long blockSize, BlockStoreLocation location, BlockMetadataView metadataView)
StorageDirView	GreedyAllocator.allocateBlockWithView(long sessionId, long blockSize, BlockStoreLocation location, BlockMetadataView metadataView)
StorageDirView	RoundRobinAllocator.allocateBlockWithView(long sessionId, long blockSize, BlockStoreLocation location, BlockMetadataView metadataView)
StorageDirView	Allocator.allocateBlockWithView(long sessionId, long blockSize, BlockStoreLocation location, BlockMetadataView view) Allocates a block from the given block store location under a given view.

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()
protected BlockStoreLocation	PartialLRUEvictor.updateBlockStoreLocation(long bytesToBeAvailable, BlockStoreLocation location)
protected BlockStoreLocation	AbstractEvictor.updateBlockStoreLocation(long bytesToBeAvailable, BlockStoreLocation location) Updates the block store location if the evictor wants to free space in a specific location.

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) A recursive implementation of cascading eviction.
EvictionPlan	GreedyEvictor.freeSpaceWithView(long availableBytes, BlockStoreLocation location, BlockMetadataEvictorView view)
EvictionPlan	AbstractEvictor.freeSpaceWithView(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView view)
EvictionPlan	Evictor.freeSpaceWithView(long availableBytes, BlockStoreLocation location, BlockMetadataEvictorView view) Frees space with the guaranteed mode.
EvictionPlan	GreedyEvictor.freeSpaceWithView(long availableBytes, BlockStoreLocation location, BlockMetadataEvictorView view, Evictor.Mode mode)
EvictionPlan	LRFUEvictor.freeSpaceWithView(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView view, Evictor.Mode mode)
EvictionPlan	AbstractEvictor.freeSpaceWithView(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView view, Evictor.Mode mode)
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.
static StorageDirView	EvictorUtils.getDirWithMaxFreeSpace(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView metadataView) Gets StorageDirView with max free space.
void	LRFUEvictor.onCommitBlock(long userId, long blockId, BlockStoreLocation location)
void	LRUEvictor.onCommitBlock(long sessionId, long blockId, BlockStoreLocation location)
static StorageDirView	EvictorUtils.selectDirWithRequestedSpace(long bytesToBeAvailable, BlockStoreLocation location, BlockMetadataEvictorView mManagerView) Finds a directory in the given location range with capacity upwards of the given bound.
protected BlockStoreLocation	PartialLRUEvictor.updateBlockStoreLocation(long bytesToBeAvailable, BlockStoreLocation location)
protected BlockStoreLocation	AbstractEvictor.updateBlockStoreLocation(long bytesToBeAvailable, BlockStoreLocation location) Updates the block store location if the evictor wants to free space in a specific location.

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

Constructor and Description
BlockTransferInfo(long blockId, BlockStoreLocation srcLocation, BlockStoreLocation dstLocation) Creates a new instance of BlockTransferInfo.

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.meta

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

Modifier and Type	Method and Description
BlockStoreLocation	AbstractBlockMeta.getBlockLocation()
BlockStoreLocation	StorageDirView.toBlockStoreLocation() Creates a BlockStoreLocation for this directory view.
BlockStoreLocation	StorageDir.toBlockStoreLocation()