alluxio.worker.block

Interface BlockStoreEventListener

All Known Implementing Classes:

AbstractBlockStoreEventListener, AbstractEvictor, BlockHeartbeatReporter, BlockMetricsReporter, LRUEvictor

public interface BlockStoreEventListener

A listener interface for receiving metadata mutation events of BlockStore. All the callback methods are triggered only after the actual event has been completed successfully.

All methods may be called concurrently, thus listener implementation needs to ensure thread-safety.

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.

Method Detail

onAccessBlock

void onAccessBlock(long sessionId,
                   long blockId)

Actions when accessing a block.

Parameters:

sessionId - the id of the session to access this block

blockId - the id of the block to access

onAccessBlock

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

Actions when accessing a block.

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

void onAbortBlock(long sessionId,
                  long blockId)

Actions when aborting a temporary block.

Parameters:

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

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

onCommitBlock

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

Actions when committing a temporary block to a BlockStoreLocation.

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

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

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

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

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

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

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

void onRemoveBlockByClient(long sessionId,
                           long blockId)

Actions when removing an existing block.

Parameters:

sessionId - the id of the session to remove this block

blockId - the id of the block to be removed

onRemoveBlockByWorker

void onRemoveBlockByWorker(long sessionId,
                           long blockId)

Actions when removing an existing block by worker.

Parameters:

sessionId - the id of the session to remove this block

blockId - the id of the block to be removed

onRemoveBlock

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

Actions when removing an existing block.

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

void onBlockLost(long blockId)

Actions when a block is lost.

Parameters:

blockId - the id of the lost block

onStorageLost

void onStorageLost(String tierAlias,
                   String dirPath)

Actions when a storage dir is lost.

Parameters:

tierAlias - the tier alias of this storage

dirPath - the directory path of this storage

onStorageLost

void onStorageLost(BlockStoreLocation dirLocation)

Actions when a storage dir is lost.

Parameters:

dirLocation - the location of this storage