alluxio.worker.block.management

Class DefaultStoreLoadTracker

java.lang.Object

alluxio.worker.block.management.DefaultStoreLoadTracker

All Implemented Interfaces:

BlockClientListener, StoreLoadTracker

public class DefaultStoreLoadTracker
extends Object
implements StoreLoadTracker, BlockClientListener

Default StoreLoadTracker that reports load based on open reader/writer streams to the local block store. TODO(ggezer): Add a safety net against close calls not being called.

Constructor Summary

Constructors

Constructor and Description
DefaultStoreLoadTracker() Creates the default load tracker instance.

Method Summary

Modifier and Type	Method and Description
void	clientClosed(BlockClient blockClient, BlockStoreLocation location) Called when an open block client is closed.
void	clientOpened(BlockClient blockClient, BlockStoreLocation location) Called when a new block client is opened.
boolean	loadDetected(BlockStoreLocation... locations) Used to detect load on particular location.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStoreLoadTracker

public DefaultStoreLoadTracker()

Creates the default load tracker instance.

Method Detail

loadDetected

public boolean loadDetected(BlockStoreLocation... locations)

Description copied from interface: StoreLoadTracker

Used to detect load on particular location.

Specified by:

loadDetected in interface StoreLoadTracker

Parameters:

locations - vararg of locations

Returns:

true if load detected on any given location

clientOpened

public void clientOpened(BlockClient blockClient,
                         BlockStoreLocation location)

Description copied from interface: BlockClientListener

Called when a new block client is opened.

Specified by:

clientOpened in interface BlockClientListener

Parameters:

blockClient - the block read/write client

location - the block location

clientClosed

public void clientClosed(BlockClient blockClient,
                         BlockStoreLocation location)

Description copied from interface: BlockClientListener

Called when an open block client is closed.

Specified by:

clientClosed in interface BlockClientListener

Parameters:

blockClient - the block read/write client

location - the block location