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