Uses of Interface
org.apache.flink.runtime.checkpoint.CompletedCheckpointStore

Packages that use CompletedCheckpointStore

Package	Description
org.apache.flink.kubernetes.highavailability
org.apache.flink.kubernetes.utils
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.util

Uses of CompletedCheckpointStore in org.apache.flink.kubernetes.highavailability

Methods in org.apache.flink.kubernetes.highavailability that return CompletedCheckpointStore

Modifier and Type	Method and Description
CompletedCheckpointStore	KubernetesCheckpointRecoveryFactory.createCheckpointStore(JobID jobID, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader)

Uses of CompletedCheckpointStore in org.apache.flink.kubernetes.utils

Methods in org.apache.flink.kubernetes.utils that return CompletedCheckpointStore

Modifier and Type	Method and Description
static CompletedCheckpointStore	KubernetesUtils.createCompletedCheckpointStore(Configuration configuration, FlinkKubeClient kubeClient, Executor executor, String configMapName, String lockIdentity, int maxNumberOfCheckpointsToRetain) Create a DefaultCompletedCheckpointStore with KubernetesStateHandleStore.

Uses of CompletedCheckpointStore in org.apache.flink.runtime.checkpoint

Classes in org.apache.flink.runtime.checkpoint that implement CompletedCheckpointStore

Modifier and Type	Class and Description
class	DefaultCompletedCheckpointStore<R extends ResourceVersion<R>> Default implementation of CompletedCheckpointStore.
class	EmbeddedCompletedCheckpointStore An embedded in-memory checkpoint store, which supports shutdown and suspend.
class	StandaloneCompletedCheckpointStore CompletedCheckpointStore for JobManagers running in HighAvailabilityMode.NONE.

Methods in org.apache.flink.runtime.checkpoint that return CompletedCheckpointStore

Modifier and Type	Method and Description
CompletedCheckpointStore	ZooKeeperCheckpointRecoveryFactory.createCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader)
CompletedCheckpointStore	StandaloneCheckpointRecoveryFactory.createCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader)
CompletedCheckpointStore	PerJobCheckpointRecoveryFactory.createCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader)
CompletedCheckpointStore	CheckpointRecoveryFactory.createCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader) Creates a CompletedCheckpointStore instance for a job.
CompletedCheckpointStore	CheckpointCoordinator.getCheckpointStore()
static CompletedCheckpointStore	CompletedCheckpointStore.storeFor(Runnable postCleanupAction, CompletedCheckpoint... checkpoints)

Methods in org.apache.flink.runtime.checkpoint with parameters of type CompletedCheckpointStore

Modifier and Type	Method and Description
static CheckpointRecoveryFactory	PerJobCheckpointRecoveryFactory.useSameServicesForAllJobs(CompletedCheckpointStore store, CheckpointIDCounter counter)

Constructors in org.apache.flink.runtime.checkpoint with parameters of type CompletedCheckpointStore

Constructor and Description
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, ExecutionVertex[] tasksToTrigger, ExecutionVertex[] tasksToWaitFor, ExecutionVertex[] tasksToCommitTo, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, StateBackend checkpointStateBackend, Executor executor, CheckpointsCleaner checkpointsCleaner, ScheduledExecutor timer, SharedStateRegistryFactory sharedStateRegistryFactory, CheckpointFailureManager failureManager)
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, ExecutionVertex[] tasksToTrigger, ExecutionVertex[] tasksToWaitFor, ExecutionVertex[] tasksToCommitTo, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, StateBackend checkpointStateBackend, Executor executor, CheckpointsCleaner checkpointsCleaner, ScheduledExecutor timer, SharedStateRegistryFactory sharedStateRegistryFactory, CheckpointFailureManager failureManager, Clock clock)

Constructor parameters in org.apache.flink.runtime.checkpoint with type arguments of type CompletedCheckpointStore

Constructor and Description
PerJobCheckpointRecoveryFactory(java.util.function.Function<Integer,CompletedCheckpointStore> completedCheckpointStorePerJobFactory, java.util.function.Supplier<CheckpointIDCounter> checkpointIDCounterPerJobFactory)

Uses of CompletedCheckpointStore in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph with parameters of type CompletedCheckpointStore

Modifier and Type

Method and Description

void

ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig, List<ExecutionJobVertex> verticesToTrigger, List<ExecutionJobVertex> verticesToWaitFor, List<ExecutionJobVertex> verticesToCommitTo, List<MasterTriggerRestoreHook<?>> masterHooks, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore checkpointStore, StateBackend checkpointStateBackend, CheckpointStatsTracker statsTracker)

Uses of CompletedCheckpointStore in org.apache.flink.runtime.util

Methods in org.apache.flink.runtime.util that return CompletedCheckpointStore

Modifier and Type	Method and Description
static CompletedCheckpointStore	ZooKeeperUtils.createCompletedCheckpoints(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration configuration, JobID jobId, int maxNumberOfCheckpointsToRetain, Executor executor) Creates a DefaultCompletedCheckpointStore instance with ZooKeeperStateHandleStore.