alluxio.worker.block

Class BlockHeartbeatReporter

java.lang.Object

alluxio.worker.block.AbstractBlockStoreEventListener

alluxio.worker.block.BlockHeartbeatReporter

All Implemented Interfaces:

BlockStoreEventListener

@ThreadSafe
public final 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 alluxio.worker.block.BlockWorker#commitBlock(long, long).

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
BlockHeartbeatReport	generateReport() Generates the report of the block store delta in the last heartbeat period.
void	onBlockLost(long blockId) Actions when a block is lost.
void	onMoveBlockByClient(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a client from a BlockStoreLocation to another.
void	onMoveBlockByWorker(long sessionId, long blockId, BlockStoreLocation oldLocation, BlockStoreLocation newLocation) Actions when moving a block by a worker from a BlockStoreLocation to another.
void	onRemoveBlockByClient(long sessionId, long blockId) Actions when removing an existing block.
void	onRemoveBlockByWorker(long sessionId, 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, onCommitBlock, 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

generateReport

public BlockHeartbeatReport generateReport()

Generates the report of the block store delta in the last heartbeat period. Calling this method marks the end of a period and the start of a new heartbeat period.

Returns:

the block store delta report for the last heartbeat period

onMoveBlockByClient

public void onMoveBlockByClient(long sessionId,
                                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:

sessionId - the id of the session to move this block

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 sessionId,
                                  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:

sessionId - the id of the session to remove this block

blockId - the id of the block to be removed

onRemoveBlockByWorker

public void onRemoveBlockByWorker(long sessionId,
                                  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:

sessionId - the id of the session to remove this block

blockId - the id of the block to be removed

onMoveBlockByWorker

public void onMoveBlockByWorker(long sessionId,
                                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:

sessionId - the id of the session to move this block

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