Uses of Class
org.apache.flink.kubernetes.highavailability.KubernetesCheckpointRecoveryFactory

Packages that use KubernetesCheckpointRecoveryFactory

Package	Description
org.apache.flink.kubernetes.highavailability

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

Methods in org.apache.flink.kubernetes.highavailability that return KubernetesCheckpointRecoveryFactory

Modifier and Type	Method	Description
static KubernetesCheckpointRecoveryFactory	KubernetesCheckpointRecoveryFactory.withLeadershipValidation(FlinkKubeClient kubeClient, org.apache.flink.configuration.Configuration configuration, Executor executor, String clusterId, Function<org.apache.flink.api.common.JobID,String> function, String lockIdentity)
static KubernetesCheckpointRecoveryFactory	KubernetesCheckpointRecoveryFactory.withoutLeadershipValidation(FlinkKubeClient kubeClient, org.apache.flink.configuration.Configuration configuration, Executor executor, String clusterId, Function<org.apache.flink.api.common.JobID,String> function)