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

Packages that use CheckpointIDCounter

Package	Description
org.apache.flink.kubernetes.highavailability
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.scheduler

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

Classes in org.apache.flink.kubernetes.highavailability that implement CheckpointIDCounter

Modifier and Type	Class and Description
class	KubernetesCheckpointIDCounter CheckpointIDCounter implementation for Kubernetes.

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

Modifier and Type	Method and Description
CheckpointIDCounter	KubernetesCheckpointRecoveryFactory.createCheckpointIDCounter(JobID jobID)

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

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

Modifier and Type	Class and Description
class	DeactivatedCheckpointIDCounter This class represents a CheckpointIDCounter if checkpointing is deactivated.
class	StandaloneCheckpointIDCounter CheckpointIDCounter instances for JobManagers running in HighAvailabilityMode.NONE.
class	ZooKeeperCheckpointIDCounter CheckpointIDCounter instances for JobManagers running in HighAvailabilityMode.ZOOKEEPER.

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

Modifier and Type	Method and Description
CheckpointIDCounter	CheckpointRecoveryFactory.createCheckpointIDCounter(JobID jobId) Creates a CheckpointIDCounter instance for a job.
CheckpointIDCounter	PerJobCheckpointRecoveryFactory.createCheckpointIDCounter(JobID jobId)
CheckpointIDCounter	StandaloneCheckpointRecoveryFactory.createCheckpointIDCounter(JobID ignored)
CheckpointIDCounter	ZooKeeperCheckpointRecoveryFactory.createCheckpointIDCounter(JobID jobID)

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

Constructor and Description
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, CheckpointStorage checkpointStorage, Executor executor, CheckpointsCleaner checkpointsCleaner, ScheduledExecutor timer, CheckpointFailureManager failureManager, CheckpointPlanCalculator checkpointPlanCalculator, CheckpointStatsTracker statsTracker)
CheckpointCoordinator(JobID job, CheckpointCoordinatorConfiguration chkConfig, Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore completedCheckpointStore, CheckpointStorage checkpointStorage, Executor executor, CheckpointsCleaner checkpointsCleaner, ScheduledExecutor timer, CheckpointFailureManager failureManager, CheckpointPlanCalculator checkpointPlanCalculator, Clock clock, CheckpointStatsTracker statsTracker, BiFunction<Set<ExecutionJobVertex>,Map<OperatorID,OperatorState>,VertexFinishedStateChecker> vertexFinishedStateCheckerFactory)

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

Constructor and Description
PerJobCheckpointRecoveryFactory(PerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper<T> checkpointStoreRecoveryHelper, Supplier<CheckpointIDCounter> checkpointIDCounterPerJobFactory)

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

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

Modifier and Type	Method and Description
static DefaultExecutionGraph	DefaultExecutionGraphBuilder.buildGraph(JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, ClassLoader classLoader, CompletedCheckpointStore completedCheckpointStore, CheckpointsCleaner checkpointsCleaner, CheckpointIDCounter checkpointIdCounter, Time rpcTimeout, BlobWriter blobWriter, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint, ExecutionDeploymentListener executionDeploymentListener, ExecutionStateUpdateListener executionStateUpdateListener, long initializationTimestamp, VertexAttemptNumberStore vertexAttemptNumberStore, VertexParallelismStore vertexParallelismStore, Supplier<CheckpointStatsTracker> checkpointStatsTrackerFactory, boolean isDynamicGraph, ExecutionJobVertex.Factory executionJobVertexFactory, MarkPartitionFinishedStrategy markPartitionFinishedStrategy, boolean nonFinishedHybridPartitionShouldBeUnknown, JobManagerJobMetricGroup jobManagerJobMetricGroup)
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)

Uses of CheckpointIDCounter in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler that return CheckpointIDCounter

Modifier and Type	Method and Description
static CheckpointIDCounter	SchedulerUtils.createCheckpointIDCounterIfCheckpointingIsEnabled(JobGraph jobGraph, CheckpointRecoveryFactory checkpointRecoveryFactory)

Methods in org.apache.flink.runtime.scheduler with parameters of type CheckpointIDCounter

Modifier and Type	Method and Description
ExecutionGraph	DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph, CompletedCheckpointStore completedCheckpointStore, CheckpointsCleaner checkpointsCleaner, CheckpointIDCounter checkpointIdCounter, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint, long initializationTimestamp, VertexAttemptNumberStore vertexAttemptNumberStore, VertexParallelismStore vertexParallelismStore, ExecutionStateUpdateListener executionStateUpdateListener, MarkPartitionFinishedStrategy markPartitionFinishedStrategy, org.slf4j.Logger log)
ExecutionGraph	ExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph, CompletedCheckpointStore completedCheckpointStore, CheckpointsCleaner checkpointsCleaner, CheckpointIDCounter checkpointIdCounter, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint, long initializationTimestamp, VertexAttemptNumberStore vertexAttemptNumberStore, VertexParallelismStore vertexParallelismStore, ExecutionStateUpdateListener executionStateUpdateListener, MarkPartitionFinishedStrategy markPartitionFinishedStrategy, org.slf4j.Logger log) Create and restore ExecutionGraph from the given JobGraph and services.