alluxio.worker.block.annotator

Class EmulatingBlockIterator

java.lang.Object

alluxio.worker.block.annotator.EmulatingBlockIterator

All Implemented Interfaces:

BlockIterator

public class EmulatingBlockIterator
extends Object
implements BlockIterator

This is used to support deprecated Evictor implementations. It works by assuming an order in the eviction plan generated by the evictor.

Constructor Summary

Constructors

Constructor and Description
EmulatingBlockIterator(BlockMetadataManager metadataManager, Evictor evictor) Creates a block iterator that emulates an Evictor.

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

EmulatingBlockIterator

public EmulatingBlockIterator(BlockMetadataManager metadataManager,
                              Evictor evictor)

Creates a block iterator that emulates an Evictor.

Parameters:

metadataManager - the metadata manager

evictor - the evictor

Method Detail

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

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