CheckpointCoordinator(JobID job,
CheckpointCoordinatorConfiguration chkConfig,
Collection<OperatorCoordinatorCheckpointContext> coordinatorsToCheckpoint,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore completedCheckpointStore,
CheckpointStorage checkpointStorage,
Executor executor,
CheckpointsCleaner checkpointsCleaner,
ScheduledExecutor timer,
SharedStateRegistryFactory sharedStateRegistryFactory,
CheckpointFailureManager failureManager,
CheckpointPlanCalculator checkpointPlanCalculator,
ExecutionAttemptMappingProvider attemptMappingProvider,
Clock clock) |