alluxio.worker.block

Class BlockMetricsReporter

java.lang.Object

alluxio.worker.block.AbstractBlockStoreEventListener

alluxio.worker.block.BlockMetricsReporter

All Implemented Interfaces:

BlockStoreEventListener

@ThreadSafe
public final class BlockMetricsReporter
extends AbstractBlockStoreEventListener

This class listens on block events and increases the metrics counters.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	onAbortBlock(long sessionId, long blockId) Actions when aborting a temporary block.
void	onAccessBlock(long sessionId, long blockId) Actions when accessing a block.
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.

Methods inherited from class alluxio.worker.block.AbstractBlockStoreEventListener

onAccessBlock, onCommitBlock, onRemoveBlock, onStorageLost, onStorageLost

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockMetricsReporter

public BlockMetricsReporter()

Creates a new instance of BlockMetricsReporter.

Method Detail

onAccessBlock

public void onAccessBlock(long sessionId,
                          long blockId)

Description copied from interface: BlockStoreEventListener

Actions when accessing a block.

Specified by:

onAccessBlock in interface BlockStoreEventListener

Overrides:

onAccessBlock in class AbstractBlockStoreEventListener

Parameters:

sessionId - the id of the session to access this block

blockId - the id of the block to access

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

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

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

onAbortBlock

public void onAbortBlock(long sessionId,
                         long blockId)

Description copied from interface: BlockStoreEventListener

Actions when aborting a temporary block.

Specified by:

onAbortBlock in interface BlockStoreEventListener

Overrides:

onAbortBlock in class AbstractBlockStoreEventListener

Parameters:

sessionId - the id of the session to abort on this block

blockId - the id of the block where the mutation to abort

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