Modifier and Type | Method and Description |
---|---|
<V> MasterTriggerRestoreHook<V> |
MasterTriggerRestoreHook.Factory.create()
Instantiates the
MasterTriggerRestoreHook . |
Modifier and Type | Method and Description |
---|---|
boolean |
CheckpointCoordinator.addMasterHook(MasterTriggerRestoreHook<?> hook)
Adds the given master hook to the checkpoint coordinator.
|
Modifier and Type | Method and Description |
---|---|
static <T> MasterTriggerRestoreHook<T> |
MasterHooks.wrapHook(MasterTriggerRestoreHook<T> hook,
ClassLoader userClassLoader)
Wraps a hook such that the user-code classloader is applied when the hook is invoked.
|
Modifier and Type | Method and Description |
---|---|
static <T> MasterTriggerRestoreHook<T> |
MasterHooks.wrapHook(MasterTriggerRestoreHook<T> hook,
ClassLoader userClassLoader)
Wraps a hook such that the user-code classloader is applied when the hook is invoked.
|
Modifier and Type | Method and Description |
---|---|
static void |
MasterHooks.restoreMasterHooks(Map<String,MasterTriggerRestoreHook<?>> masterHooks,
Collection<MasterState> states,
long checkpointId,
boolean allowUnmatchedState,
org.slf4j.Logger log)
Calls the restore method given checkpoint master hooks and passes the given master
state to them where state with a matching name is found.
|
static List<MasterState> |
MasterHooks.triggerMasterHooks(Collection<MasterTriggerRestoreHook<?>> hooks,
long checkpointId,
long timestamp,
Executor executor,
Time timeout)
Triggers all given master hooks and returns state objects for each hook that
produced a state.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.enableCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizeSettings,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
String checkpointDir,
StateBackend metadataStore,
CheckpointStatsTracker statsTracker) |
Modifier and Type | Method and Description |
---|---|
MasterTriggerRestoreHook<E> |
WithMasterCheckpointHook.createMasterTriggerRestoreHook()
Creates the hook that should be called by the checkpoint coordinator.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.