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 sessionId, long blockId) Actions when aborting a temporary block.
void	onAccessBlock(long sessionId, long blockId) Actions when accessing a block.
void	onAccessBlock(long sessionId, long blockId, BlockStoreLocation location) Actions when accessing a block.
void	onBlockLost(long blockId) Actions when a block is lost.
void	onCommitBlock(long sessionId, long blockId, BlockStoreLocation location) Actions when committing a temporary block to a BlockStoreLocation.
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	onRemoveBlock(long sessionId, long blockId, BlockStoreLocation location) Actions when removing an existing block.
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(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 sessionId,
                          long blockId)

Description copied from interface: BlockStoreEventListener

Actions when accessing a block.

Specified by:

onAccessBlock in interface BlockStoreEventListener

Parameters:

sessionId - the id of the session to access this block

blockId - the id of the block to access

onAccessBlock

public void onAccessBlock(long sessionId,
                          long blockId,
                          BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when accessing a block.

Specified by:

onAccessBlock in interface BlockStoreEventListener

Parameters:

sessionId - the id of the session to access this block

blockId - the id of the block to access

location - the location of the block

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

Parameters:

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

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

onCommitBlock

public void onCommitBlock(long sessionId,
                          long blockId,
                          BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when committing a temporary block to a BlockStoreLocation.

Specified by:

onCommitBlock in interface BlockStoreEventListener

Parameters:

sessionId - the id of the session to commit to this block

blockId - the id of the block to commit

location - the location of the block to be committed

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

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

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

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

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

Parameters:

sessionId - the id of the session to remove this block

blockId - the id of the block to be removed

onRemoveBlock

public void onRemoveBlock(long sessionId,
                          long blockId,
                          BlockStoreLocation location)

Description copied from interface: BlockStoreEventListener

Actions when removing an existing block.

Specified by:

onRemoveBlock in interface BlockStoreEventListener

Parameters:

sessionId - the id of the session to remove this block

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