alluxio.worker.block

Class AsyncBlockRemover

java.lang.Object

alluxio.worker.block.AsyncBlockRemover

@ThreadSafe
public class AsyncBlockRemover
extends Object

Asynchronous block removal service.

Constructor Summary

Constructors

Constructor and Description
AsyncBlockRemover(BlockWorker worker) Constructor of AsyncBlockRemover.
AsyncBlockRemover(BlockWorker worker, int threads, BlockingQueue<Long> blocksToRemove, Set<Long> removingBlocks) Constructor of AsyncBlockRemover.

Method Summary

Modifier and Type	Method and Description
void	addBlocksToDelete(List<Long> blocks) Put blocks into async block remover.
void	shutDown() Shutdown async block remover.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncBlockRemover

public AsyncBlockRemover(BlockWorker worker)

Constructor of AsyncBlockRemover.

Parameters:

worker - block worker

AsyncBlockRemover

public AsyncBlockRemover(BlockWorker worker,
                         int threads,
                         BlockingQueue<Long> blocksToRemove,
                         Set<Long> removingBlocks)

Constructor of AsyncBlockRemover.

Parameters:

worker - block worker

threads - number of threads

blocksToRemove - blocks to remove

removingBlocks - blocks being removed

Method Detail

addBlocksToDelete

public void addBlocksToDelete(List<Long> blocks)

Put blocks into async block remover. This method will take care of the duplicate blocks.

Parameters:

blocks - blocks to be deleted

shutDown

public void shutDown()

Shutdown async block remover.