Package | Description |
---|---|
org.apache.flink.kubernetes.highavailability |
Modifier and Type | Method and Description |
---|---|
static KubernetesCheckpointRecoveryFactory |
KubernetesCheckpointRecoveryFactory.withLeadershipValidation(FlinkKubeClient kubeClient,
Configuration configuration,
Executor executor,
String clusterId,
java.util.function.Function<JobID,String> function,
String lockIdentity) |
static KubernetesCheckpointRecoveryFactory |
KubernetesCheckpointRecoveryFactory.withoutLeadershipValidation(FlinkKubeClient kubeClient,
Configuration configuration,
Executor executor,
String clusterId,
java.util.function.Function<JobID,String> function) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.