alluxio.worker.block

Class BlockHeartbeatReport

java.lang.Object

alluxio.worker.block.BlockHeartbeatReport

@ThreadSafe
public final class BlockHeartbeatReport
extends Object

Container for the delta information in each worker-to-master heartbeat.

Constructor Summary

Constructors

Constructor and Description
BlockHeartbeatReport(Map<BlockStoreLocation,List<Long>> addedBlocks, List<Long> removedBlocks, Map<String,List<String>> lostStorage) Creates a new instance of BlockHeartbeatReport.

Method Summary

Modifier and Type	Method and Description
Map<BlockStoreLocation,List<Long>>	getAddedBlocks() Gets the list of blocks added by the worker in the heartbeat this report represents.
Map<String,List<String>>	getLostStorage() Gets the storage paths which were lost in the heartbeat this report represents.
List<Long>	getRemovedBlocks() Gets the list of blocks removed from this worker in the heartbeat this report represents.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockHeartbeatReport

public BlockHeartbeatReport(Map<BlockStoreLocation,List<Long>> addedBlocks,
                            List<Long> removedBlocks,
                            Map<String,List<String>> lostStorage)

Creates a new instance of BlockHeartbeatReport.

Parameters:

addedBlocks - added blocks

removedBlocks - remove blocks

lostStorage - lost storage

Method Detail

getAddedBlocks

public Map<BlockStoreLocation,List<Long>> getAddedBlocks()

Gets the list of blocks added by the worker in the heartbeat this report represents.

Returns:

a map from storage location to lists of block ids added

getRemovedBlocks

public List<Long> getRemovedBlocks()

Gets the list of blocks removed from this worker in the heartbeat this report represents.

Returns:

a list of block ids which have been removed

getLostStorage

public Map<String,List<String>> getLostStorage()

Gets the storage paths which were lost in the heartbeat this report represents.

Returns:

a map from storage tier alias to lost storage paths