Uses of Class
org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration

Packages that use CheckpointCoordinatorConfiguration

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobgraph.tasks

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

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

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, ExecutionAttemptMappingProvider attemptMappingProvider, 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, ExecutionAttemptMappingProvider attemptMappingProvider, Clock clock, CheckpointStatsTracker statsTracker, java.util.function.BiFunction<Set<ExecutionJobVertex>,Map<OperatorID,OperatorState>,VertexFinishedStateChecker> vertexFinishedStateCheckerFactory)

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

Methods in org.apache.flink.runtime.executiongraph that return CheckpointCoordinatorConfiguration

Modifier and Type	Method and Description
CheckpointCoordinatorConfiguration	ArchivedExecutionGraph.getCheckpointCoordinatorConfiguration()
CheckpointCoordinatorConfiguration	AccessExecutionGraph.getCheckpointCoordinatorConfiguration() Returns the CheckpointCoordinatorConfiguration or null if checkpointing is disabled.
CheckpointCoordinatorConfiguration	DefaultExecutionGraph.getCheckpointCoordinatorConfiguration()

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

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)
void	ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig, List<MasterTriggerRestoreHook<?>> masterHooks, CheckpointIDCounter checkpointIDCounter, CompletedCheckpointStore checkpointStore, StateBackend checkpointStateBackend, CheckpointStorage checkpointStorage, CheckpointStatsTracker statsTracker, CheckpointsCleaner checkpointsCleaner)

Constructors in org.apache.flink.runtime.executiongraph with parameters of type CheckpointCoordinatorConfiguration

Constructor and Description

ArchivedExecutionGraph(JobID jobID, String jobName, Map<JobVertexID,ArchivedExecutionJobVertex> tasks, List<ArchivedExecutionJobVertex> verticesInCreationOrder, long[] stateTimestamps, JobStatus state, ErrorInfo failureCause, String jsonPlan, StringifiedAccumulatorResult[] archivedUserAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators, ArchivedExecutionConfig executionConfig, boolean isStoppable, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, CheckpointStatsSnapshot checkpointStatsSnapshot, String stateBackendName, String checkpointStorageName)

Uses of CheckpointCoordinatorConfiguration in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks that return CheckpointCoordinatorConfiguration

Modifier and Type	Method and Description
CheckpointCoordinatorConfiguration	CheckpointCoordinatorConfiguration.CheckpointCoordinatorConfigurationBuilder.build()
CheckpointCoordinatorConfiguration	JobCheckpointingSettings.getCheckpointCoordinatorConfiguration()

Constructors in org.apache.flink.runtime.jobgraph.tasks with parameters of type CheckpointCoordinatorConfiguration

Constructor and Description
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend)
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend, TernaryBoolean changelogStateBackendEnabled, SerializedValue<CheckpointStorage> defaultCheckpointStorage, SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)