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

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

Modifier and Type	Method and Description
CheckpointCoordinatorConfiguration	CheckpointStatsTracker.getJobCheckpointingConfiguration() Returns the job's checkpointing configuration which is derived from the CheckpointConfig.

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

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)
CheckpointStatsTracker(int numRememberedCheckpoints, List<ExecutionJobVertex> jobVertices, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, MetricGroup metricGroup) Creates a new checkpoint stats tracker.

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	ExecutionGraph.getCheckpointCoordinatorConfiguration()
CheckpointCoordinatorConfiguration	ArchivedExecutionGraph.getCheckpointCoordinatorConfiguration()
CheckpointCoordinatorConfiguration	AccessExecutionGraph.getCheckpointCoordinatorConfiguration() Returns the CheckpointCoordinatorConfiguration or null if checkpointing is disabled.

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

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)

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)

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(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend)
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend, SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)