alluxio.worker.block

Class BlockMetadataEvictorView

java.lang.Object

alluxio.worker.block.BlockMetadataView

alluxio.worker.block.BlockMetadataEvictorView

@NotThreadSafe
public class BlockMetadataEvictorView
extends BlockMetadataView

This class exposes a narrower view of BlockMetadataManager to Evictors, filtering out un-evictable blocks and un-allocatable space internally, so that evictors and allocators can be developed with much simpler logic, without worrying about various constraints, e.g. pinned files, locked blocks, etc. TODO(cc): Filter un-allocatable space.

Field Summary

Fields inherited from class alluxio.worker.block.BlockMetadataView

mMetadataManager, mUseReservedSpace

Constructor Summary

Constructors

Constructor and Description
BlockMetadataEvictorView(BlockMetadataManager manager, Set<Long> pinnedInodes, Set<Long> lockedBlocks) Creates a new instance of BlockMetadataEvictorView.

Method Summary

Modifier and Type	Method and Description
void	clearBlockMarks() Clears all marks of blocks to move in/out in all dir views.
long	getAvailableBytes(BlockStoreLocation location) Gets available bytes given certain location BlockMetadataManager.getAvailableBytes(BlockStoreLocation).
Optional<BlockMeta>	getBlockMeta(long blockId) Returns Optional.empty() if block is pinned or currently being locked, otherwise returns BlockMetadataManager.getBlockMeta(long).
List<StorageDirView>	getDirs(BlockStoreLocation location) Gets all dir views that belongs to a given location.
protected void	initializeView() Used to initialize the view based on the current metadata status.
boolean	isBlockEvictable(long blockId) Tests if the block is evictable.
boolean	isBlockLocked(long blockId) Tests if the block is locked.
boolean	isBlockMarked(long blockId) Tests if the block is marked to move out of its current dir in this view.
boolean	isBlockPinned(long blockId) Tests if the block is pinned either explicitly or because it is scheduled for async persist.

Methods inherited from class alluxio.worker.block.BlockMetadataView

getNextTier, getTierView, getTierViews, getTierViewsBelow, refreshView

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlockMetadataEvictorView

public BlockMetadataEvictorView(BlockMetadataManager manager,
                                Set<Long> pinnedInodes,
                                Set<Long> lockedBlocks)

Creates a new instance of BlockMetadataEvictorView. Now we always create a new view before freespace.

Parameters:

manager - which the view should be constructed from

pinnedInodes - a set of pinned inodes

lockedBlocks - a set of locked blocks

Method Detail

initializeView

protected void initializeView()

Description copied from class: BlockMetadataView

Used to initialize the view based on the current metadata status.

Specified by:

initializeView in class BlockMetadataView

getDirs

public List<StorageDirView> getDirs(BlockStoreLocation location)

Gets all dir views that belongs to a given location.

Parameters:

location - the location

Returns:

the list of dir views

clearBlockMarks

public void clearBlockMarks()

Clears all marks of blocks to move in/out in all dir views.

isBlockPinned

public boolean isBlockPinned(long blockId)

Tests if the block is pinned either explicitly or because it is scheduled for async persist.

Parameters:

blockId - to be tested

Returns:

boolean, true if block is pinned

isBlockLocked

public boolean isBlockLocked(long blockId)

Tests if the block is locked.

Parameters:

blockId - to be tested

Returns:

boolean, true if block is locked

isBlockEvictable

public boolean isBlockEvictable(long blockId)

Tests if the block is evictable.

Parameters:

blockId - to be tested

Returns:

boolean, true if the block can be evicted

isBlockMarked

public boolean isBlockMarked(long blockId)

Tests if the block is marked to move out of its current dir in this view.

Parameters:

blockId - the id of the block

Returns:

boolean, true if the block is marked to move out

getAvailableBytes

public long getAvailableBytes(BlockStoreLocation location)

Gets available bytes given certain location BlockMetadataManager.getAvailableBytes(BlockStoreLocation). Throws an IllegalArgumentException if the location does not belong to tiered storage.

Parameters:

location - location the check available bytes

Returns:

available bytes

getBlockMeta

public Optional<BlockMeta> getBlockMeta(long blockId)

Returns Optional.empty() if block is pinned or currently being locked, otherwise returns BlockMetadataManager.getBlockMeta(long).

Parameters:

blockId - the block id

Returns:

metadata of the block or null