Package | Description |
---|---|
org.apache.flink.kubernetes | |
org.apache.flink.kubernetes.highavailability | |
org.apache.flink.kubernetes.kubeclient | |
org.apache.flink.kubernetes.utils |
Constructor and Description |
---|
KubernetesClusterDescriptor(Configuration flinkConfig,
FlinkKubeClient client) |
KubernetesResourceManagerDriver(Configuration flinkConfig,
FlinkKubeClient flinkKubeClient,
KubernetesResourceManagerDriverConfiguration configuration) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
Fabric8FlinkKubeClient
The implementation of
FlinkKubeClient . |
Modifier and Type | Method and Description |
---|---|
FlinkKubeClient |
FlinkKubeClientFactory.fromConfiguration(Configuration flinkConfig,
String useCase)
Create a Flink Kubernetes client with the given configuration.
|
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpointStore |
KubernetesUtils.createCompletedCheckpointStore(Configuration configuration,
FlinkKubeClient kubeClient,
Executor executor,
String configMapName,
String lockIdentity,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode)
Create a
DefaultCompletedCheckpointStore with KubernetesStateHandleStore . |
static void |
KubernetesUtils.createConfigMapIfItDoesNotExist(FlinkKubeClient flinkKubeClient,
String configMapName,
String clusterId)
Creates a config map with the given name if it does not exist.
|
static KubernetesStateHandleStore<JobGraph> |
KubernetesUtils.createJobGraphStateHandleStore(Configuration configuration,
FlinkKubeClient flinkKubeClient,
String configMapName,
String lockIdentity)
Create a
KubernetesStateHandleStore which storing JobGraph . |
static JobGraphStore |
KubernetesUtils.createJobGraphStore(Configuration configuration,
FlinkKubeClient flinkKubeClient,
String configMapName,
String lockIdentity)
Create a
DefaultJobGraphStore with NoOpJobGraphStoreWatcher . |
static FlinkPod |
KubernetesUtils.loadPodFromTemplateFile(FlinkKubeClient kubeClient,
File podTemplateFile,
String mainContainerName) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.