alluxio.worker.block.management

Class BlockTransferExecutor

java.lang.Object

alluxio.worker.block.management.BlockTransferExecutor

public class BlockTransferExecutor
extends Object

Used to execute list of BlockTransferInfo orders concurrently.

Constructor Summary

Constructors

Constructor and Description
BlockTransferExecutor(ExecutorService executor, LocalBlockStore blockStore, StoreLoadTracker loadTracker, int concurrencyLimit) Creates a new instance for executing block transfers.

Method Summary

Modifier and Type	Method and Description
BlockOperationResult	executeTransferList(List<BlockTransferInfo> transferInfos) Executes given list of BlockTransferInfos.
BlockOperationResult	executeTransferList(List<BlockTransferInfo> transferInfos, java.util.function.Consumer<Exception> exceptionHandler) Executes given list of BlockTransferInfos.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockTransferExecutor

public BlockTransferExecutor(ExecutorService executor,
                             LocalBlockStore blockStore,
                             StoreLoadTracker loadTracker,
                             int concurrencyLimit)

Creates a new instance for executing block transfers.

Parameters:

executor - the executor to use

blockStore - the block store

loadTracker - the load tracker

concurrencyLimit - the max concurrent transfers

Method Detail

executeTransferList

public BlockOperationResult executeTransferList(List<BlockTransferInfo> transferInfos)

Executes given list of BlockTransferInfos.

Parameters:

transferInfos - the list of transfers

Returns:

the result of transfers

executeTransferList

public BlockOperationResult executeTransferList(List<BlockTransferInfo> transferInfos,
                                                java.util.function.Consumer<Exception> exceptionHandler)

Executes given list of BlockTransferInfos.

Parameters:

transferInfos - the list of transfers

exceptionHandler - exception handler for when a transfer fails

Returns:

the result of transfers