alluxio.worker.block.management.tier

Class SwapRestoreTask

java.lang.Object

alluxio.worker.block.management.AbstractBlockManagementTask

alluxio.worker.block.management.tier.SwapRestoreTask

All Implemented Interfaces:

BlockManagementTask

public class SwapRestoreTask
extends AbstractBlockManagementTask

Block management task that is used to free up space on reserved spaces of each directory. It's required to guarantee termination of AlignTasks under variable block size. It essentially does a full cascading evict followed by balancing of each directory.

Field Summary

Fields inherited from class alluxio.worker.block.management.AbstractBlockManagementTask

mBlockStore, mEvictorView, mExecutor, mLoadTracker, mMetadataManager, mTransferExecutor

Constructor Summary

Constructors

Constructor and Description
SwapRestoreTask(LocalBlockStore blockStore, BlockMetadataManager metadataManager, BlockMetadataEvictorView evictorView, StoreLoadTracker loadTracker, ExecutorService executor) Creates a new swap-restore task.

Method Summary

Modifier and Type	Method and Description
BlockManagementTaskResult	run() Run management task.

Methods inherited from class java.lang.Object

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

Constructor Detail

SwapRestoreTask

public SwapRestoreTask(LocalBlockStore blockStore,
                       BlockMetadataManager metadataManager,
                       BlockMetadataEvictorView evictorView,
                       StoreLoadTracker loadTracker,
                       ExecutorService executor)

Creates a new swap-restore task.

Parameters:

blockStore - the block store

metadataManager - the meta manager

evictorView - the evictor view

loadTracker - the load tracker

executor - the executor

Method Detail

run

public BlockManagementTaskResult run()

Description copied from interface: BlockManagementTask

Run management task.

Returns:

the task result