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 | 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)
Create a
DefaultCompletedCheckpointStore with KubernetesStateHandleStore . |
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–2022 The Apache Software Foundation. All rights reserved.