alluxio.worker.block

Class BlockMetadataManagerView

java.lang.Object

alluxio.worker.block.BlockMetadataManagerView

@NotThreadSafe
public class BlockMetadataManagerView
extends Object

This class exposes a narrower view of BlockMetadataManager to Evictors and Allocators, 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.

Constructor Summary

Constructors

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

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).
BlockMeta	getBlockMeta(long blockId) Returns null if block is pinned or currently being locked, otherwise returns BlockMetadataManager.getBlockMeta(long).
StorageTierView	getNextTier(StorageTierView tierView) Gets the next storage tier view.
StorageTierView	getTierView(String tierAlias) Provides StorageTierView given tierAlias.
List<StorageTierView>	getTierViews() Gets all tierViews under this managerView.
List<StorageTierView>	getTierViewsBelow(String tierAlias) Gets all tierViews before certain tierView.
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockMetadataManagerView

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

Creates a new instance of BlockMetadataManagerView. 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

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.

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

getTierView

public StorageTierView getTierView(String tierAlias)

Provides StorageTierView given tierAlias. Throws an IllegalArgumentException if the tierAlias is not found.

Parameters:

tierAlias - the alias of this tierView

Returns:

the StorageTierView object associated with the alias

getTierViews

public List<StorageTierView> getTierViews()

Gets all tierViews under this managerView.

Returns:

the list of StorageTierViews

getTierViewsBelow

public List<StorageTierView> getTierViewsBelow(String tierAlias)

Gets all tierViews before certain tierView. Throws an IllegalArgumentException if the tierAlias is not found.

Parameters:

tierAlias - the alias of a tierView

Returns:

the list of StorageTierView

getNextTier

@Nullable
public StorageTierView getNextTier(StorageTierView tierView)

Gets the next storage tier view.

Parameters:

tierView - the storage tier view

Returns:

the next storage tier view, null if this is the last tier view

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

@Nullable
public BlockMeta getBlockMeta(long blockId)
                                 throws BlockDoesNotExistException

Returns null 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

Throws:

BlockDoesNotExistException - if no BlockMeta for this block id is found