Package org.apache.flink.kubernetes.highavailability

Class KubernetesCheckpointRecoveryFactory

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesCheckpointRecoveryFactory

All Implemented Interfaces:

org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory

public class KubernetesCheckpointRecoveryFactory
extends Object
implements org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory

Factory to create CompletedCheckpointStore and CheckpointIDCounter.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.runtime.checkpoint.CheckpointIDCounter	createCheckpointIDCounter(org.apache.flink.api.common.JobID jobID)
org.apache.flink.runtime.checkpoint.CompletedCheckpointStore	createRecoveredCompletedCheckpointStore(org.apache.flink.api.common.JobID jobID, int maxNumberOfCheckpointsToRetain, org.apache.flink.runtime.state.SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, org.apache.flink.runtime.jobgraph.RestoreMode restoreMode)
static 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	withoutLeadershipValidation(FlinkKubeClient kubeClient, org.apache.flink.configuration.Configuration configuration, Executor executor, String clusterId, Function<org.apache.flink.api.common.JobID,String> function)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createRecoveredCompletedCheckpointStore

public org.apache.flink.runtime.checkpoint.CompletedCheckpointStore createRecoveredCompletedCheckpointStore(org.apache.flink.api.common.JobID jobID,
                                                                                                            int maxNumberOfCheckpointsToRetain,
                                                                                                            org.apache.flink.runtime.state.SharedStateRegistryFactory sharedStateRegistryFactory,
                                                                                                            Executor ioExecutor,
                                                                                                            org.apache.flink.runtime.jobgraph.RestoreMode restoreMode)
                                                                                                     throws Exception

Specified by:

createRecoveredCompletedCheckpointStore in interface org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory

Throws:

Exception

createCheckpointIDCounter

public org.apache.flink.runtime.checkpoint.CheckpointIDCounter createCheckpointIDCounter(org.apache.flink.api.common.JobID jobID)
                                                                                  throws Exception

Specified by:

createCheckpointIDCounter in interface org.apache.flink.runtime.checkpoint.CheckpointRecoveryFactory

Throws:

Exception

withLeadershipValidation

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

withoutLeadershipValidation

public static KubernetesCheckpointRecoveryFactory withoutLeadershipValidation(FlinkKubeClient kubeClient,
                                                                              org.apache.flink.configuration.Configuration configuration,
                                                                              Executor executor,
                                                                              String clusterId,
                                                                              Function<org.apache.flink.api.common.JobID,String> function)