alluxio.master.meta

Class JournalSpaceMonitor

java.lang.Object

alluxio.master.meta.JournalSpaceMonitor

All Implemented Interfaces:

HeartbeatExecutor, java.io.Closeable, java.lang.AutoCloseable

public class JournalSpaceMonitor
extends java.lang.Object
implements HeartbeatExecutor

A heartbeat executor which periodically tracks the amount of disk space available for a particular path, generally the disk holding the journal. This monitor is only applicable to systems which are running on the Linux OS and which are running the embedded journal. Other configurations are invalid. Running this monitor on such systems is undefined behavior.

Constructor Summary

Constructors

Constructor and Description
JournalSpaceMonitor(AlluxioConfiguration configuration) Convenience method for JournalSpaceMonitor(String, long).
JournalSpaceMonitor(java.lang.String journalPath, long warnCapacityPercentThreshold)

Method Summary

Modifier and Type	Method and Description
void	close()
protected java.util.List<JournalDiskInfo>	getDiskInfo() Gets the current disk information from the system for the journal path.
java.util.List<java.lang.String>	getJournalDiskWarnings()
void	heartbeat()

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalSpaceMonitor

public JournalSpaceMonitor(AlluxioConfiguration configuration)

Convenience method for JournalSpaceMonitor(String, long).

Parameters:

configuration - the current alluxio configuration

JournalSpaceMonitor

public JournalSpaceMonitor(java.lang.String journalPath,
                           long warnCapacityPercentThreshold)

Parameters:

journalPath - the path to the journal location

warnCapacityPercentThreshold - when a device utilization falls below this threshold, emit warnings to the log

Method Detail

getDiskInfo

protected java.util.List<JournalDiskInfo> getDiskInfo()
                                               throws java.io.IOException

Gets the current disk information from the system for the journal path.

Returns:

a list of the disks that back the journal path. Many systems will just have one disk. Depending on the configuration multiple disks may back the journal path, in which case we report information on all of them

Throws:

java.io.IOException - when obtaining the disk information fails

getJournalDiskWarnings

public java.util.List<java.lang.String> getJournalDiskWarnings()

Returns:

a list warning messages that can be logged or displayed to the user in the UI

heartbeat

public void heartbeat()
               throws java.lang.InterruptedException

Specified by:

heartbeat in interface HeartbeatExecutor

Throws:

java.lang.InterruptedException

close

public void close()

Specified by:

close in interface HeartbeatExecutor

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable