alluxio.worker.block

Class BlockHeartbeatReporter

java.lang.Object

alluxio.worker.block.AbstractBlockStoreEventListener

alluxio.worker.block.BlockHeartbeatReporter

All Implemented Interfaces:

BlockStoreEventListener

@ThreadSafe
public class BlockHeartbeatReporter
extends AbstractBlockStoreEventListener

Represents the delta of the block store within one heartbeat period. For now, newly committed blocks do not pass through this master communication mechanism, instead it is synchronized through BlockWorker.commitBlock(long, long, boolean).

Constructor Summary

Constructors

Constructor and Description
BlockHeartbeatReporter() Creates a new instance of BlockHeartbeatReporter.

Method Summary

Modifier and Type	Method and Description
void	clear() Clears the internal states of the reporter.
BlockHeartbeatReport	generateReportAndClear() Generates the report of the report and clear the states.
void	mergeBack(BlockHeartbeatReport previousReport) Merges back the cleared block lists/maps given a generated report.
void	onBlockLost(long blockId) Actions when a block is lost.
void	onMoveBlockByClient(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a client from a BlockStoreLocation to another.
void	onMoveBlockByWorker(long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a worker from a BlockStoreLocation to another.
void	onRemoveBlockByClient(long blockId) Actions when removing an existing block.
void	onRemoveBlockByWorker(long blockId) Actions when removing an existing block by worker.
void	onStorageLost(String tierAlias, String dirPath) Actions when a storage dir is lost.

Methods inherited from class alluxio.worker.block.AbstractBlockStoreEventListener

onAbortBlock, onAccessBlock, onAccessBlock, onCommitBlockToLocal, onCommitBlockToMaster, onRemoveBlock, onStorageLost

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockHeartbeatReporter

public BlockHeartbeatReporter()

Creates a new instance of BlockHeartbeatReporter.

Method Detail

generateReportAndClear

public BlockHeartbeatReport generateReportAndClear()

Generates the report of the report and clear the states.

Returns:

the block store delta report for the last heartbeat period

clear

public void clear()

Clears the internal states of the reporter.

mergeBack

public void mergeBack(BlockHeartbeatReport previousReport)

Merges back the cleared block lists/maps given a generated report. used when the worker heartbeat rpc fails.

Parameters:

previousReport - the previous generated report

onMoveBlockByClient

public void onMoveBlockByClient(long blockId,
                                BlockStoreLocation oldLocation,
                                BlockStoreLocation newLocation)

Description copied from interface: BlockStoreEventListener

Actions when moving a block by a client from a BlockStoreLocation to another.

Specified by:

onMoveBlockByClient in interface BlockStoreEventListener

Overrides:

onMoveBlockByClient in class AbstractBlockStoreEventListener

Parameters:

blockId - the id of the block to be moved

oldLocation - the source location of the block to be moved

newLocation - the destination location where the block is to be moved to

onRemoveBlockByClient

public void onRemoveBlockByClient(long blockId)

Description copied from interface: BlockStoreEventListener

Actions when removing an existing block.

Specified by:

onRemoveBlockByClient in interface BlockStoreEventListener

Overrides:

onRemoveBlockByClient in class AbstractBlockStoreEventListener

Parameters:

blockId - the id of the block to be removed

onRemoveBlockByWorker

public void onRemoveBlockByWorker(long blockId)

Description copied from interface: BlockStoreEventListener

Actions when removing an existing block by worker.

Specified by:

onRemoveBlockByWorker in interface BlockStoreEventListener

Overrides:

onRemoveBlockByWorker in class AbstractBlockStoreEventListener

Parameters:

blockId - the id of the block to be removed

onMoveBlockByWorker

public void onMoveBlockByWorker(long blockId,
                                BlockStoreLocation oldLocation,
                                BlockStoreLocation newLocation)

Description copied from interface: BlockStoreEventListener

Actions when moving a block by a worker from a BlockStoreLocation to another.

Specified by:

onMoveBlockByWorker in interface BlockStoreEventListener

Overrides:

onMoveBlockByWorker in class AbstractBlockStoreEventListener

Parameters:

blockId - the id of the block to be moved

oldLocation - the source location of the block to be moved

newLocation - the destination location where the block is to be moved to

onBlockLost

public void onBlockLost(long blockId)

Description copied from interface: BlockStoreEventListener

Actions when a block is lost.

Specified by:

onBlockLost in interface BlockStoreEventListener

Overrides:

onBlockLost in class AbstractBlockStoreEventListener

Parameters:

blockId - the id of the lost block

onStorageLost

public void onStorageLost(String tierAlias,
                          String dirPath)

Description copied from interface: BlockStoreEventListener

Actions when a storage dir is lost.

Specified by:

onStorageLost in interface BlockStoreEventListener

Overrides:

onStorageLost in class AbstractBlockStoreEventListener

Parameters:

tierAlias - the tier alias of this storage

dirPath - the directory path of this storage