public final class CheckpointingContext
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CHECKPOINTING_ENABLED |
static java.lang.String |
CHECKPOINTING_RESTORE_JOB |
static java.lang.String |
CHECKPOINTING_SOURCE_FREQUNCY |
static java.lang.String |
CHECKPOINTING_STORE_CLASS |
static java.lang.String |
JOB_MASTER_USED |
Modifier and Type | Method and Description |
---|---|
static long |
getCheckPointingFrequency(Config config) |
static java.lang.String |
getCheckpointingStoreClass(Config config) |
static boolean |
isCheckpointingEnabled(Config config) |
static boolean |
isNfsUsed(Config config) |
static boolean |
startingFromACheckpoint(Config config) |
public static final java.lang.String JOB_MASTER_USED
public static final java.lang.String CHECKPOINTING_ENABLED
public static final java.lang.String CHECKPOINTING_STORE_CLASS
public static final java.lang.String CHECKPOINTING_SOURCE_FREQUNCY
public static final java.lang.String CHECKPOINTING_RESTORE_JOB
public static boolean isCheckpointingEnabled(Config config)
public static java.lang.String getCheckpointingStoreClass(Config config)
public static boolean startingFromACheckpoint(Config config)
public static long getCheckPointingFrequency(Config config)
public static boolean isNfsUsed(Config config)