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.

Field Summary

Fields

Modifier and Type	Field and Description
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_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_PERSISTENCE_CHECKER
static String	MASTER_PERSISTENCE_SCHEDULER
static String	MASTER_REPLICATION_CHECK
static String	MASTER_TABLE_TRANSFORMATION_MONITOR
static String	MASTER_TTL_CHECK
static String	MASTER_UFS_CLEANUP
static String	META_MASTER_CONFIG_HASH_SYNC
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

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_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_BLOCK_INTEGRITY_CHECK

public static final String MASTER_BLOCK_INTEGRITY_CHECK

See Also:

Constant Field Values

MASTER_CLUSTER_METRICS_UPDATER

public static final String MASTER_CLUSTER_METRICS_UPDATER

See Also:

Constant Field Values

MASTER_CHECKPOINT_SCHEDULING

public static final String MASTER_CHECKPOINT_SCHEDULING

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_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_UFS_CLEANUP

public static final String MASTER_UFS_CLEANUP

See Also:

Constant Field Values

MASTER_TTL_CHECK

public static final String MASTER_TTL_CHECK

See Also:

Constant Field Values

MASTER_ACTIVE_UFS_SYNC

public static final String MASTER_ACTIVE_UFS_SYNC

See Also:

Constant Field Values

MASTER_TABLE_TRANSFORMATION_MONITOR

public static final String MASTER_TABLE_TRANSFORMATION_MONITOR

See Also:

Constant Field Values

META_MASTER_SYNC

public static final String META_MASTER_SYNC

See Also:

Constant Field Values

META_MASTER_CONFIG_HASH_SYNC

public static final String META_MASTER_CONFIG_HASH_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

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