alluxio.worker.block

Class AbstractBlockStoreEventListener

java.lang.Object

alluxio.worker.block.AbstractBlockStoreEventListener

All Implemented Interfaces:

BlockStoreEventListener

Direct Known Subclasses:

AbstractEvictor, BlockHeartbeatReporter, BlockMetricsReporter

@NotThreadSafe
public abstract class AbstractBlockStoreEventListener
extends Object
implements BlockStoreEventListener

A block store event listener base class implementing the BlockStoreEventListener interface with empty methods bodies.

Constructor Summary

Constructors

Constructor and Description
AbstractBlockStoreEventListener()

Method Summary

Modifier and Type	Method and Description
void	onAbortBlock(long blockId) Actions when aborting a temporary block.
void	onAccessBlock(long blockId) Actions when accessing a block.
void	onAccessBlock(long blockId, BlockStoreLocation location) Actions when accessing a block.
void	onBlockLost(long blockId) Actions when a block is lost.
void	onCommitBlockToLocal(long blockId, BlockStoreLocation location) Actions when committing a temporary block to a BlockStoreLocation at local block store.
void	onCommitBlockToMaster(long blockId, BlockStoreLocation location) Actions when a temporary block has been committed to the alluxio master.
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	onRemoveBlock(long blockId, BlockStoreLocation location) Actions when removing an existing block.
void	onRemoveBlockByClient(long blockId) Actions when removing an existing block.
void	onRemoveBlockByWorker(long blockId) Actions when removing an existing block by worker.
void	onStorageLost(BlockStoreLocation dirLocation) Actions when a storage dir is lost.
void	onStorageLost(String tierAlias, String dirPath) Actions when a storage dir is lost.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractBlockStoreEventListener

public AbstractBlockStoreEventListener()

Method Detail

onAccessBlock

public void onAccessBlock(long blockId)

Description copied from interface: BlockStoreEventListener

Actions when accessing a block.

Specified by:

onAccessBlock in interface BlockStoreEventListener

Parameters:

blockId - the id of the block to access

onAccessBlock

public void onAccessBlock(long blockId,
                          BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when accessing a block.

Specified by:

onAccessBlock in interface BlockStoreEventListener

Parameters:

blockId - the id of the block to access

location - the location of the block

onAbortBlock

public void onAbortBlock(long blockId)

Description copied from interface: BlockStoreEventListener

Actions when aborting a temporary block.

Specified by:

onAbortBlock in interface BlockStoreEventListener

Parameters:

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

onCommitBlockToLocal

public void onCommitBlockToLocal(long blockId,
                                 BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when committing a temporary block to a BlockStoreLocation at local block store.

Specified by:

onCommitBlockToLocal in interface BlockStoreEventListener

Parameters:

blockId - the id of the block to commit

location - the location of the block to be committed

onCommitBlockToMaster

public void onCommitBlockToMaster(long blockId,
                                  BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when a temporary block has been committed to the alluxio master.

Specified by:

onCommitBlockToMaster in interface BlockStoreEventListener

Parameters:

blockId - the id of the block to commit

location - the location of the block to be committed

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

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

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

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

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

Parameters:

blockId - the id of the block to be removed

onRemoveBlock

public void onRemoveBlock(long blockId,
                          BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when removing an existing block.

Specified by:

onRemoveBlock in interface BlockStoreEventListener

Parameters:

blockId - the id of the block to be removed

location - the location of the block to be removed

onBlockLost

public void onBlockLost(long blockId)

Description copied from interface: BlockStoreEventListener

Actions when a block is lost.

Specified by:

onBlockLost in interface BlockStoreEventListener

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

Parameters:

tierAlias - the tier alias of this storage

dirPath - the directory path of this storage

onStorageLost

public void onStorageLost(BlockStoreLocation dirLocation)

Description copied from interface: BlockStoreEventListener

Actions when a storage dir is lost.

Specified by:

onStorageLost in interface BlockStoreEventListener

Parameters:

dirLocation - the location of this storage