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> CompletableFuture<MasterState> |
MasterHooks.triggerHook(MasterTriggerRestoreHook<T> hook,
long checkpointId,
long timestamp,
Executor executor)
Trigger master hook and return a completable future with state.
|
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.close(Collection<MasterTriggerRestoreHook<?>> hooks,
org.slf4j.Logger log)
Closes the master hooks.
|
static void |
MasterHooks.reset(Collection<MasterTriggerRestoreHook<?>> hooks,
org.slf4j.Logger log)
Resets the master hooks.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner,
String changelogStorageName) |
void |
ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner,
String changelogStorage) |
Modifier and Type | Method and Description |
---|---|
MasterTriggerRestoreHook<E> |
WithMasterCheckpointHook.createMasterTriggerRestoreHook()
Creates the hook that should be called by the checkpoint coordinator.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.