Uses of Interface org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory (Flink : 2.0-SNAPSHOT API)

Packages that use CheckpointRecoveryFactory
Package	Description
org.apache.flink.kubernetes.highavailability
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha
org.apache.flink.runtime.highavailability.nonha.embedded
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.adaptivebatch

Uses of CheckpointRecoveryFactory in org.apache.flink.kubernetes.highavailability

Classes in org.apache.flink.kubernetes.highavailability that implement CheckpointRecoveryFactory
Modifier and Type	Class	Description
`class`	`KubernetesCheckpointRecoveryFactory`	Factory to create `CompletedCheckpointStore` and `CheckpointIDCounter`.

Methods in org.apache.flink.kubernetes.highavailability that return CheckpointRecoveryFactory
Modifier and Type	Method	Description
`protected CheckpointRecoveryFactory`	KubernetesLeaderElectionHaServices.`createCheckpointRecoveryFactory()`

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

Classes in org.apache.flink.runtime.checkpoint that implement CheckpointRecoveryFactory
Modifier and Type	Class	Description
`class`	`PerJobCheckpointRecoveryFactory<T extends CompletedCheckpointStore>`	Simple `CheckpointRecoveryFactory` which creates and keeps separate `CompletedCheckpointStore` and `CheckpointIDCounter` for each `JobID`.
`class`	`StandaloneCheckpointRecoveryFactory`	`CheckpointCoordinator` components in `HighAvailabilityMode.NONE`.
`class`	`ZooKeeperCheckpointRecoveryFactory`	`CheckpointCoordinator` components in `HighAvailabilityMode.ZOOKEEPER`.

Methods in org.apache.flink.runtime.checkpoint that return CheckpointRecoveryFactory
Modifier and Type	Method	Description
`static <T extends CompletedCheckpointStore> CheckpointRecoveryFactory`	PerJobCheckpointRecoveryFactory.`withoutCheckpointStoreRecovery(IntFunction<T> storeFn)`

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.dispatcher.cleanup

Methods in org.apache.flink.runtime.dispatcher.cleanup with parameters of type CheckpointRecoveryFactory
Modifier and Type	Method	Description
`CheckpointResourcesCleanupRunner`	CheckpointResourcesCleanupRunnerFactory.`create(JobResult jobResult, CheckpointRecoveryFactory checkpointRecoveryFactory, Configuration configuration, Executor cleanupExecutor)`
`JobManagerRunner`	CleanupRunnerFactory.`create(JobResult jobResult, CheckpointRecoveryFactory checkpointRecoveryFactory, Configuration configuration, Executor cleanupExecutor)`

Constructors in org.apache.flink.runtime.dispatcher.cleanup with parameters of type CheckpointRecoveryFactory
Constructor	Description
`CheckpointResourcesCleanupRunner(JobResult jobResult, CheckpointRecoveryFactory checkpointRecoveryFactory, SharedStateRegistryFactory sharedStateRegistryFactory, Configuration jobManagerConfiguration, Executor cleanupExecutor, long initializationTimestamp)`

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.highavailability

Methods in org.apache.flink.runtime.highavailability that return CheckpointRecoveryFactory
Modifier and Type	Method	Description
`protected abstract CheckpointRecoveryFactory`	AbstractHaServices.`createCheckpointRecoveryFactory()`	Create the checkpoint recovery factory for the job manager.
`CheckpointRecoveryFactory`	AbstractHaServices.`getCheckpointRecoveryFactory()`
`CheckpointRecoveryFactory`	HighAvailabilityServices.`getCheckpointRecoveryFactory()`	Gets the checkpoint recovery factory for the job manager.

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.highavailability.nonha

Methods in org.apache.flink.runtime.highavailability.nonha that return CheckpointRecoveryFactory
Modifier and Type	Method	Description
`CheckpointRecoveryFactory`	AbstractNonHaServices.`getCheckpointRecoveryFactory()`

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.highavailability.nonha.embedded

Methods in org.apache.flink.runtime.highavailability.nonha.embedded that return CheckpointRecoveryFactory
Modifier and Type	Method	Description
`CheckpointRecoveryFactory`	EmbeddedHaServicesWithLeadershipControl.`getCheckpointRecoveryFactory()`

Constructors in org.apache.flink.runtime.highavailability.nonha.embedded with parameters of type CheckpointRecoveryFactory
Constructor	Description
`EmbeddedHaServicesWithLeadershipControl(Executor executor, CheckpointRecoveryFactory checkpointRecoveryFactory)`

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.highavailability.zookeeper

Methods in org.apache.flink.runtime.highavailability.zookeeper that return CheckpointRecoveryFactory
Modifier and Type	Method	Description
`CheckpointRecoveryFactory`	ZooKeeperLeaderElectionHaServices.`createCheckpointRecoveryFactory()`

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with parameters of type CheckpointRecoveryFactory
Modifier and Type	Method	Description
`SchedulerNG`	DefaultSlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log, ExecutionPlan executionPlan, Executor ioExecutor, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Duration slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
`SchedulerNG`	SlotPoolServiceSchedulerFactory.createScheduler(org.slf4j.Logger log, ExecutionPlan executionPlan, Executor ioExecutor, Configuration configuration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Duration slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)	Creates a `SchedulerNG`.

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type CheckpointRecoveryFactory
Modifier and Type	Method	Description
`static CheckpointIDCounter`	SchedulerUtils.`createCheckpointIDCounterIfCheckpointingIsEnabled(JobGraph jobGraph, CheckpointRecoveryFactory checkpointRecoveryFactory)`
`static CompletedCheckpointStore`	SchedulerUtils.`createCompletedCheckpointStoreIfCheckpointingIsEnabled(JobGraph jobGraph, Configuration configuration, CheckpointRecoveryFactory checkpointRecoveryFactory, Executor ioExecutor, org.slf4j.Logger log)`
`SchedulerNG`	DefaultSchedulerFactory.createInstance(org.slf4j.Logger log, ExecutionPlan executionPlan, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Duration slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
`SchedulerNG`	SchedulerNGFactory.createInstance(org.slf4j.Logger log, ExecutionPlan executionPlan, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Duration slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)

Constructors in org.apache.flink.runtime.scheduler with parameters of type CheckpointRecoveryFactory
Constructor	Description
DefaultScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Duration rpcTimeout, VertexParallelismStore vertexParallelismStore, ExecutionDeployer.Factory executionDeployerFactory)
SchedulerBase(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, ExecutionVertexVersioner executionVertexVersioner, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, ExecutionGraphFactory executionGraphFactory, VertexParallelismStore vertexParallelismStore)

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type CheckpointRecoveryFactory
Modifier and Type	Method	Description
`SchedulerNG`	AdaptiveSchedulerFactory.createInstance(org.slf4j.Logger log, ExecutionPlan executionPlan, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Duration slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)

Constructors in org.apache.flink.runtime.scheduler.adaptive with parameters of type CheckpointRecoveryFactory
Constructor	Description
AdaptiveScheduler(AdaptiveScheduler.Settings settings, JobGraph jobGraph, JobResourceRequirements jobResourceRequirements, Configuration configuration, DeclarativeSlotPool declarativeSlotPool, SlotAllocator slotAllocator, Executor ioExecutor, ClassLoader userCodeClassLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, RestartBackoffTimeStrategy restartBackoffTimeStrategy, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory)

Uses of CheckpointRecoveryFactory in org.apache.flink.runtime.scheduler.adaptivebatch

Methods in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type CheckpointRecoveryFactory
Modifier and Type	Method	Description
`SchedulerNG`	AdaptiveBatchSchedulerFactory.createInstance(org.slf4j.Logger log, ExecutionPlan executionPlan, Executor ioExecutor, Configuration jobMasterConfiguration, SlotPoolService slotPoolService, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, Duration slotRequestTimeout, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, FatalErrorHandler fatalErrorHandler, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations)
`static AdaptiveBatchScheduler`	AdaptiveBatchSchedulerFactory.createScheduler(org.slf4j.Logger log, JobGraph jobGraph, ExecutionConfig executionConfig, Executor ioExecutor, Configuration jobMasterConfiguration, ScheduledExecutorService futureExecutor, ClassLoader userCodeLoader, CheckpointRecoveryFactory checkpointRecoveryFactory, Duration rpcTimeout, BlobWriter blobWriter, JobManagerJobMetricGroup jobManagerJobMetricGroup, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, ExecutionDeploymentTracker executionDeploymentTracker, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, BlocklistOperations blocklistOperations, ExecutionOperations executionOperations, ExecutionSlotAllocatorFactory allocatorFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ScheduledExecutor delayExecutor, VertexParallelismAndInputInfosDecider vertexParallelismAndInputInfosDecider, BatchJobRecoveryHandler jobRecoveryHandler)

Constructors in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type CheckpointRecoveryFactory
Constructor	Description
AdaptiveBatchScheduler(org.slf4j.Logger log, JobGraph jobGraph, Executor ioExecutor, Configuration jobMasterConfiguration, Consumer<ComponentMainThreadExecutor> startUpAction, ScheduledExecutor delayExecutor, ClassLoader userCodeLoader, CheckpointsCleaner checkpointsCleaner, CheckpointRecoveryFactory checkpointRecoveryFactory, JobManagerJobMetricGroup jobManagerJobMetricGroup, SchedulingStrategyFactory schedulingStrategyFactory, FailoverStrategy.Factory failoverStrategyFactory, RestartBackoffTimeStrategy restartBackoffTimeStrategy, ExecutionOperations executionOperations, ExecutionVertexVersioner executionVertexVersioner, ExecutionSlotAllocatorFactory executionSlotAllocatorFactory, long initializationTimestamp, ComponentMainThreadExecutor mainThreadExecutor, JobStatusListener jobStatusListener, Collection<FailureEnricher> failureEnrichers, ExecutionGraphFactory executionGraphFactory, ShuffleMaster<?> shuffleMaster, Duration rpcTimeout, VertexParallelismAndInputInfosDecider vertexParallelismAndInputInfosDecider, int defaultMaxParallelism, BlocklistOperations blocklistOperations, JobManagerOptions.HybridPartitionDataConsumeConstraint hybridPartitionDataConsumeConstraint, Map<JobVertexID,ForwardGroup> forwardGroupsByJobVertexId, BatchJobRecoveryHandler jobRecoveryHandler)