alluxio.worker.block.annotator

Class DefaultBlockIterator

java.lang.Object

alluxio.worker.block.annotator.DefaultBlockIterator

All Implemented Interfaces:

BlockIterator

public class DefaultBlockIterator
extends Object
implements BlockIterator

The default BlockIterator implementation that integrates with the BlockMetadataManager.

Constructor Summary

Constructors

Constructor and Description
DefaultBlockIterator(BlockMetadataManager metaManager, BlockAnnotator blockAnnotator) Creates default block iterator instance.

Method Summary

Modifier and Type	Method and Description
boolean	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>	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>	getIterator(BlockStoreLocation location, BlockOrder order) Gets an iterator of block-Ids.
List<BlockStoreEventListener>	getListeners() Used to acquire and register listeners that are used by this iterator.
Pair<List<Long>,List<Long>>	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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBlockIterator

public DefaultBlockIterator(BlockMetadataManager metaManager,
                            BlockAnnotator blockAnnotator)

Creates default block iterator instance.

Parameters:

metaManager - meta manager

blockAnnotator - block annotator

Method Detail

getListeners

public List<BlockStoreEventListener> getListeners()

Description copied from interface: BlockIterator

Used to acquire and register listeners that are used by this iterator.

Specified by:

getListeners in interface BlockIterator

Returns:

list of event listeners

getIterator

public Iterator<Long> getIterator(BlockStoreLocation location,
                                  BlockOrder order)

Description copied from interface: BlockIterator

Gets an iterator of block-Ids.

Specified by:

getIterator in interface BlockIterator

Parameters:

location - location to iterate for blocks

order - order of blocks

Returns:

an iterator

getIntersectionList

public List<Long> getIntersectionList(BlockStoreLocation srcLocation,
                                      BlockOrder srcOrder,
                                      BlockStoreLocation dstLocation,
                                      BlockOrder dstOrder,
                                      int intersectionWidth,
                                      BlockOrder intersectionOrder,
                                      java.util.function.Function<Long,Boolean> blockFilterFunc)

Description copied from interface: BlockIterator

Used to get blocks within an intersection of locations in sorted order. It receives a filter using which certain blocks could be excluded from intersection iterator.

Specified by:

getIntersectionList in interface BlockIterator

Parameters:

srcLocation - source location

srcOrder - order for the source location

dstLocation - destination location

dstOrder - order for the destination location

intersectionWidth - width of intersection

intersectionOrder - the order of intersected blocks

blockFilterFunc - a filter for blocks

Returns:

list of blocks in intersection

getSwaps

public Pair<List<Long>,List<Long>> getSwaps(BlockStoreLocation srcLocation,
                                            BlockOrder srcOrder,
                                            BlockStoreLocation dstLocation,
                                            BlockOrder dstOrder,
                                            int swapRange,
                                            BlockOrder intersectionOrder,
                                            java.util.function.Function<Long,Boolean> blockFilterFunc)

Description copied from interface: BlockIterator

Used to list of blocks, that if swapped, could eliminate overlap between two tiers. It receives a filter using which certain blocks could be excluded from intersection iterator.

Specified by:

getSwaps in interface BlockIterator

Parameters:

srcLocation - source location

srcOrder - order for the source location

dstLocation - destination location

dstOrder - order for the destination location

swapRange - per-tier range of swap

intersectionOrder - the order of intersected blocks

blockFilterFunc - a filter for blocks

Returns:

2 list of blocks to swap

aligned

public boolean aligned(BlockStoreLocation srcLocation,
                       BlockStoreLocation dstLocation,
                       BlockOrder order,
                       java.util.function.Function<Long,Boolean> blockFilterFunc)

Description copied from interface: BlockIterator

Used to detect presence of an overlap between two locations. Overlap will be decided based on configured eviction order policy. It receives a filter using which certain blocks could be excluded from overlap decision.

Specified by:

aligned in interface BlockIterator

Parameters:

srcLocation - source location

dstLocation - destination location

order - order of comparison between locations

blockFilterFunc - a filter for blocks

Returns:

true if tiers are aligned