@ThreadSafe public final class HeartbeatContext extends Object
Modifier and Type | Field and Description |
---|---|
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_TTL_CHECK |
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 |
Modifier and Type | Method and Description |
---|---|
static Class<? extends HeartbeatTimer> |
getTimerClass(String name) |
static Map<String,Class<? extends HeartbeatTimer>> |
getTimerClasses() |
public static final Class<? extends HeartbeatTimer> SCHEDULED_TIMER_CLASS
public static final Class<? extends HeartbeatTimer> SLEEPING_TIMER_CLASS
public static final String MASTER_BLOCK_INTEGRITY_CHECK
public static final String MASTER_CLUSTER_METRICS_UPDATER
public static final String MASTER_CHECKPOINT_SCHEDULING
public static final String MASTER_DAILY_BACKUP
public static final String MASTER_FILE_RECOMPUTATION
public static final String MASTER_LOG_CONFIG_REPORT_SCHEDULING
public static final String MASTER_LOST_FILES_DETECTION
public static final String MASTER_LOST_MASTER_DETECTION
public static final String MASTER_LOST_WORKER_DETECTION
public static final String MASTER_METRICS_SYNC
public static final String MASTER_TTL_CHECK
public static final String META_MASTER_SYNC
public static final String WORKER_BLOCK_SYNC
public static final String WORKER_CLIENT
public static final String WORKER_FILESYSTEM_MASTER_SYNC
public static final String WORKER_PIN_LIST_SYNC
public static final String WORKER_SPACE_RESERVER
public static Map<String,Class<? extends HeartbeatTimer>> getTimerClasses()
public static Class<? extends HeartbeatTimer> getTimerClass(String name)
name
- a name of a heartbeat executor threadCopyright © 2023. All Rights Reserved.