alluxio.worker.block.management

Class BlockTransferPartitioner

java.lang.Object

alluxio.worker.block.management.BlockTransferPartitioner

public class BlockTransferPartitioner
extends Object

Used to partition transfers for concurrent execution.

Constructor Summary

Constructors

Constructor and Description
BlockTransferPartitioner()

Method Summary

Modifier and Type	Method and Description
List<List<BlockTransferInfo>>	partitionTransfers(List<BlockTransferInfo> transferInfos, int maxPartitionCount) It greedily partitions given transfers into sub-lists.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockTransferPartitioner

public BlockTransferPartitioner()

Method Detail

partitionTransfers

public List<List<BlockTransferInfo>> partitionTransfers(List<BlockTransferInfo> transferInfos,
                                                        int maxPartitionCount)

It greedily partitions given transfers into sub-lists.

Parameters:

transferInfos - list of transfers to partition

maxPartitionCount - max partition count

Returns:

transfers partitioned into sub-lists