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

Packages that use CheckpointRecoveryFactory

Package	Description
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.highavailability
org.apache.flink.runtime.highavailability.nonha
org.apache.flink.runtime.highavailability.zookeeper
org.apache.flink.yarn.highavailability

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

Classes in org.apache.flink.runtime.checkpoint that implement CheckpointRecoveryFactory

Modifier and Type	Class and Description
class	StandaloneCheckpointRecoveryFactory CheckpointCoordinator components in HighAvailabilityMode.NONE.
class	ZooKeeperCheckpointRecoveryFactory CheckpointCoordinator components in HighAvailabilityMode.ZOOKEEPER.

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

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

Modifier and Type

Method and Description

static ExecutionGraph

ExecutionGraphBuilder.buildGraph(ExecutionGraph prior, JobGraph jobGraph, Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, SlotProvider slotProvider, ClassLoader classLoader, CheckpointRecoveryFactory recoveryFactory, Time timeout, RestartStrategy restartStrategy, MetricGroup metrics, int parallelismForAutoMax, BlobWriter blobWriter, org.slf4j.Logger log) Builds the ExecutionGraph from the JobGraph.

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

Methods in org.apache.flink.runtime.highavailability that return CheckpointRecoveryFactory

Modifier and Type	Method and Description
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 and Description
CheckpointRecoveryFactory	AbstractNonHaServices.getCheckpointRecoveryFactory()

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 and Description
CheckpointRecoveryFactory	ZooKeeperHaServices.getCheckpointRecoveryFactory()

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

Methods in org.apache.flink.yarn.highavailability that return CheckpointRecoveryFactory

Modifier and Type	Method and Description
CheckpointRecoveryFactory	AbstractYarnNonHaServices.getCheckpointRecoveryFactory()