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

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)

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	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)