alluxio.worker.block.management.tier

Class TierManagementTaskProvider

java.lang.Object

alluxio.worker.block.management.tier.TierManagementTaskProvider

All Implemented Interfaces:

ManagementTaskProvider

public class TierManagementTaskProvider
extends Object
implements ManagementTaskProvider

ManagementTaskProvider implementation for tier management tasks. It currently creates three types of tasks: 1- AlignTask for aligning tiers based on user access pattern. 2- SwapRestoreTask for when swap task can't run due to reserved space exhaustion. 3- PromoteTask for utilizing speed of higher tiers by moving blocks from below.

Constructor Summary

Constructors

Constructor and Description
TierManagementTaskProvider(BlockStore blockStore, BlockMetadataManager metadataManager, java.util.function.Supplier<BlockMetadataEvictorView> evictorViewSupplier, StoreLoadTracker loadTracker, ExecutorService executor) Creates a task provider for tier management functions.

Method Summary

Modifier and Type	Method and Description
BlockManagementTask	getTask()
static void	setSwapRestoreRequired(boolean swapRestoreRequired) Used to set whether swap-restore task is required.

Methods inherited from class java.lang.Object

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

Constructor Detail

TierManagementTaskProvider

public TierManagementTaskProvider(BlockStore blockStore,
                                  BlockMetadataManager metadataManager,
                                  java.util.function.Supplier<BlockMetadataEvictorView> evictorViewSupplier,
                                  StoreLoadTracker loadTracker,
                                  ExecutorService executor)

Creates a task provider for tier management functions.

Parameters:

blockStore - the block store

metadataManager - the meta manager

evictorViewSupplier - the evictor view supplier

loadTracker - the load tracker

executor - the executor

Method Detail

setSwapRestoreRequired

public static void setSwapRestoreRequired(boolean swapRestoreRequired)

Used to set whether swap-restore task is required. It's used by AlignTask when a swap fails due to insufficient reserved space.

Parameters:

swapRestoreRequired - whether swap-restore task needs to run

getTask

public BlockManagementTask getTask()

Specified by:

getTask in interface ManagementTaskProvider

Returns:

the next management task from this provider