alluxio.heartbeat

Class HeartbeatContext

java.lang.Object

alluxio.heartbeat.HeartbeatContext

@ThreadSafe
public final class HeartbeatContext
extends Object

This is a static class for storing and retrieving heartbeat related information.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HeartbeatContext.HeartbeatType HeartBeat Enum Type.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FUSE_UPDATE_CHECK
static String	JOB_MASTER_LOST_WORKER_DETECTION
static String	JOB_WORKER_COMMAND_HANDLING
static String	MASTER_ACTIVE_UFS_SYNC
static String	MASTER_BLOCK_INTEGRITY_CHECK
static String	MASTER_CHECKPOINT_SCHEDULING
static String	MASTER_CLUSTER_METRICS_UPDATER
static String	MASTER_DAILY_BACKUP
static String	MASTER_FILE_RECOMPUTATION
static String	MASTER_JOURNAL_SPACE_MONITOR
static String	MASTER_LOG_CONFIG_REPORT_SCHEDULING
static String	MASTER_LOST_FILES_DETECTION
static String	MASTER_LOST_MASTER_DETECTION
static String	MASTER_LOST_WORKER_DETECTION
static String	MASTER_METRICS_SYNC
static String	MASTER_METRICS_TIME_SERIES
static String	MASTER_ORPHANED_METRICS_CLEANER
static String	MASTER_PERSISTENCE_CHECKER
static String	MASTER_PERSISTENCE_SCHEDULER
static String	MASTER_REPLICATION_CHECK
static String	MASTER_TABLE_TRANSFORMATION_MONITOR
static String	MASTER_THROTTLE
static String	MASTER_TTL_CHECK
static String	MASTER_UFS_CLEANUP
static String	MASTER_UPDATE_CHECK
static String	MASTER_WORKER_REGISTER_SESSION_CLEANER
static String	META_MASTER_SYNC
static Class<? extends HeartbeatTimer>	SCHEDULED_TIMER_CLASS
static Class<? extends HeartbeatTimer>	SLEEPING_TIMER_CLASS
static String	WORKER_BLOCK_SYNC
static String	WORKER_CLIENT
static String	WORKER_FILESYSTEM_MASTER_SYNC
static String	WORKER_PIN_LIST_SYNC
static String	WORKER_SPACE_RESERVER
static String	WORKER_STORAGE_HEALTH

Method Summary

Modifier and Type	Method and Description
static Class<? extends HeartbeatTimer>	getTimerClass(String name)
static Map<String,Class<? extends HeartbeatTimer>>	getTimerClasses()

Methods inherited from class java.lang.Object

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

Field Detail

SCHEDULED_TIMER_CLASS

public static final Class<? extends HeartbeatTimer> SCHEDULED_TIMER_CLASS

SLEEPING_TIMER_CLASS

public static final Class<? extends HeartbeatTimer> SLEEPING_TIMER_CLASS

FUSE_UPDATE_CHECK

public static final String FUSE_UPDATE_CHECK

See Also:

Constant Field Values

JOB_MASTER_LOST_WORKER_DETECTION

public static final String JOB_MASTER_LOST_WORKER_DETECTION

See Also:

Constant Field Values

JOB_WORKER_COMMAND_HANDLING

public static final String JOB_WORKER_COMMAND_HANDLING

See Also:

Constant Field Values

MASTER_THROTTLE

public static final String MASTER_THROTTLE

See Also:

Constant Field Values

MASTER_ACTIVE_UFS_SYNC

public static final String MASTER_ACTIVE_UFS_SYNC

See Also:

Constant Field Values

MASTER_BLOCK_INTEGRITY_CHECK

public static final String MASTER_BLOCK_INTEGRITY_CHECK

See Also:

Constant Field Values

MASTER_CHECKPOINT_SCHEDULING

public static final String MASTER_CHECKPOINT_SCHEDULING

See Also:

Constant Field Values

MASTER_CLUSTER_METRICS_UPDATER

public static final String MASTER_CLUSTER_METRICS_UPDATER

See Also:

Constant Field Values

MASTER_DAILY_BACKUP

public static final String MASTER_DAILY_BACKUP

See Also:

Constant Field Values

MASTER_FILE_RECOMPUTATION

public static final String MASTER_FILE_RECOMPUTATION

See Also:

Constant Field Values

MASTER_JOURNAL_SPACE_MONITOR

public static final String MASTER_JOURNAL_SPACE_MONITOR

See Also:

Constant Field Values

MASTER_LOG_CONFIG_REPORT_SCHEDULING

public static final String MASTER_LOG_CONFIG_REPORT_SCHEDULING

See Also:

Constant Field Values

MASTER_LOST_FILES_DETECTION

public static final String MASTER_LOST_FILES_DETECTION

See Also:

Constant Field Values

MASTER_LOST_MASTER_DETECTION

public static final String MASTER_LOST_MASTER_DETECTION

See Also:

Constant Field Values

MASTER_LOST_WORKER_DETECTION

public static final String MASTER_LOST_WORKER_DETECTION

See Also:

Constant Field Values

MASTER_METRICS_SYNC

public static final String MASTER_METRICS_SYNC

See Also:

Constant Field Values

MASTER_METRICS_TIME_SERIES

public static final String MASTER_METRICS_TIME_SERIES

See Also:

Constant Field Values

MASTER_ORPHANED_METRICS_CLEANER

public static final String MASTER_ORPHANED_METRICS_CLEANER

See Also:

Constant Field Values

MASTER_PERSISTENCE_CHECKER

public static final String MASTER_PERSISTENCE_CHECKER

See Also:

Constant Field Values

MASTER_PERSISTENCE_SCHEDULER

public static final String MASTER_PERSISTENCE_SCHEDULER

See Also:

Constant Field Values

MASTER_REPLICATION_CHECK

public static final String MASTER_REPLICATION_CHECK

See Also:

Constant Field Values

MASTER_TABLE_TRANSFORMATION_MONITOR

public static final String MASTER_TABLE_TRANSFORMATION_MONITOR

See Also:

Constant Field Values

MASTER_TTL_CHECK

public static final String MASTER_TTL_CHECK

See Also:

Constant Field Values

MASTER_UFS_CLEANUP

public static final String MASTER_UFS_CLEANUP

See Also:

Constant Field Values

MASTER_UPDATE_CHECK

public static final String MASTER_UPDATE_CHECK

See Also:

Constant Field Values

META_MASTER_SYNC

public static final String META_MASTER_SYNC

See Also:

Constant Field Values

WORKER_BLOCK_SYNC

public static final String WORKER_BLOCK_SYNC

See Also:

Constant Field Values

WORKER_CLIENT

public static final String WORKER_CLIENT

See Also:

Constant Field Values

WORKER_FILESYSTEM_MASTER_SYNC

public static final String WORKER_FILESYSTEM_MASTER_SYNC

See Also:

Constant Field Values

WORKER_PIN_LIST_SYNC

public static final String WORKER_PIN_LIST_SYNC

See Also:

Constant Field Values

WORKER_SPACE_RESERVER

public static final String WORKER_SPACE_RESERVER

See Also:

Constant Field Values

WORKER_STORAGE_HEALTH

public static final String WORKER_STORAGE_HEALTH

See Also:

Constant Field Values

MASTER_WORKER_REGISTER_SESSION_CLEANER

public static final String MASTER_WORKER_REGISTER_SESSION_CLEANER

See Also:

Constant Field Values

Method Detail

getTimerClasses

public static Map<String,Class<? extends HeartbeatTimer>> getTimerClasses()

Returns:

the mapping from executor thread names to timer classes

getTimerClass

public static Class<? extends HeartbeatTimer> getTimerClass(String name)

Parameters:

name - a name of a heartbeat executor thread

Returns:

the timer class to use for the executor thread