alluxio.worker.block

Class SpaceReserver

java.lang.Object

alluxio.worker.block.SpaceReserver

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@NotThreadSafe
public class SpaceReserver
extends Object
implements HeartbeatExecutor

The SpaceReserver periodically checks the available space on each storage tier. If the used space is above the high watermark configured for the tier, eviction will be triggered to reach the low watermark. If this is not the top tier, it will also add the amount of space reserved on the tier above to reduce the impact of cascading eviction.

Constructor Summary

Constructors

Constructor and Description
SpaceReserver(BlockWorker blockWorker) Creates a new instance of SpaceReserver.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any resources used by the heartbeat executor.
void	heartbeat() Implements the heartbeat logic.
void	updateStorageInfo() Re-calculates storage spaces and watermarks.

Methods inherited from class java.lang.Object

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

Constructor Detail

SpaceReserver

public SpaceReserver(BlockWorker blockWorker)

Creates a new instance of SpaceReserver.

Parameters:

blockWorker - the block worker handle

Method Detail

updateStorageInfo

public void updateStorageInfo()

Re-calculates storage spaces and watermarks.

heartbeat

public void heartbeat()

Description copied from interface: HeartbeatExecutor

Implements the heartbeat logic.

Specified by:

heartbeat in interface HeartbeatExecutor

close

public void close()

Description copied from interface: HeartbeatExecutor

Cleans up any resources used by the heartbeat executor.

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable