Uses of Class
org.apache.flink.runtime.jobgraph.RestoreMode
-
Packages that use RestoreMode Package Description org.apache.flink.runtime.checkpoint org.apache.flink.runtime.jobgraph org.apache.flink.runtime.state org.apache.flink.runtime.util -
-
Uses of RestoreMode in org.apache.flink.runtime.checkpoint
Methods in org.apache.flink.runtime.checkpoint with parameters of type RestoreMode Modifier and Type Method Description CompletedCheckpointStoreCheckpointRecoveryFactory. createRecoveredCompletedCheckpointStore(org.apache.flink.api.common.JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode)Creates a RECOVEREDCompletedCheckpointStoreinstance for a job.CompletedCheckpointStorePerJobCheckpointRecoveryFactory. createRecoveredCompletedCheckpointStore(org.apache.flink.api.common.JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode)CompletedCheckpointStoreStandaloneCheckpointRecoveryFactory. createRecoveredCompletedCheckpointStore(org.apache.flink.api.common.JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode)CompletedCheckpointStoreZooKeeperCheckpointRecoveryFactory. createRecoveredCompletedCheckpointStore(org.apache.flink.api.common.JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode)StoreTypePerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper. recoverCheckpointStore(int maxNumberOfCheckpointsToRetain, StoreType previousStore, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode)voidCompletedCheckpoint. registerSharedStatesAfterRestored(SharedStateRegistry sharedStateRegistry, RestoreMode restoreMode)Register all shared states in the given registry.Constructors in org.apache.flink.runtime.checkpoint with parameters of type RestoreMode Constructor Description EmbeddedCompletedCheckpointStore(int maxRetainedCheckpoints, Collection<CompletedCheckpoint> initialCheckpoints, RestoreMode restoreMode)StandaloneCompletedCheckpointStore(int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode)CreatesStandaloneCompletedCheckpointStore. -
Uses of RestoreMode in org.apache.flink.runtime.jobgraph
Fields in org.apache.flink.runtime.jobgraph declared as RestoreMode Modifier and Type Field Description static RestoreModeRestoreMode. DEFAULTFields in org.apache.flink.runtime.jobgraph with type parameters of type RestoreMode Modifier and Type Field Description static org.apache.flink.configuration.ConfigOption<RestoreMode>SavepointConfigOptions. RESTORE_MODEDescribes the mode how Flink should restore from the given savepoint or retained checkpoint.Methods in org.apache.flink.runtime.jobgraph that return RestoreMode Modifier and Type Method Description RestoreModeSavepointRestoreSettings. getRestoreMode()Tells how to restore from the given savepoint.static RestoreModeRestoreMode. valueOf(String name)Returns the enum constant of this type with the specified name.static RestoreMode[]RestoreMode. values()Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.runtime.jobgraph with parameters of type RestoreMode Modifier and Type Method Description static SavepointRestoreSettingsSavepointRestoreSettings. forPath(String savepointPath, boolean allowNonRestoredState, RestoreMode restoreMode) -
Uses of RestoreMode in org.apache.flink.runtime.state
Methods in org.apache.flink.runtime.state with parameters of type RestoreMode Modifier and Type Method Description SharedStateRegistrySharedStateRegistryFactory. create(Executor deleteExecutor, Collection<CompletedCheckpoint> checkpoints, RestoreMode restoreMode)Factory method forSharedStateRegistry.voidSharedStateRegistry. registerAllAfterRestored(CompletedCheckpoint checkpoint, RestoreMode mode)Set the lowest checkpoint ID below which no state is discarded, inclusive.voidSharedStateRegistryImpl. registerAllAfterRestored(CompletedCheckpoint checkpoint, RestoreMode mode) -
Uses of RestoreMode in org.apache.flink.runtime.util
Methods in org.apache.flink.runtime.util with parameters of type RestoreMode Modifier and Type Method Description static CompletedCheckpointStoreZooKeeperUtils. createCompletedCheckpoints(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client, org.apache.flink.configuration.Configuration configuration, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, Executor executor, RestoreMode restoreMode)Creates aDefaultCompletedCheckpointStoreinstance withZooKeeperStateHandleStore.
-