Package | Description |
---|---|
org.apache.flink.kubernetes | |
org.apache.flink.kubernetes.kubeclient | |
org.apache.flink.kubernetes.kubeclient.factory |
Modifier and Type | Method and Description |
---|---|
void |
KubernetesResourceManager.onAdded(List<KubernetesPod> pods) |
void |
KubernetesResourceManager.onDeleted(List<KubernetesPod> pods) |
void |
KubernetesResourceManager.onError(List<KubernetesPod> pods) |
void |
KubernetesResourceManager.onModified(List<KubernetesPod> pods) |
Modifier and Type | Method and Description |
---|---|
List<KubernetesPod> |
FlinkKubeClient.getPodsWithLabels(Map<String,String> labels)
List the pods with specified labels.
|
List<KubernetesPod> |
Fabric8FlinkKubeClient.getPodsWithLabels(Map<String,String> labels) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
FlinkKubeClient.createTaskManagerPod(KubernetesPod kubernetesPod)
Create task manager pod.
|
CompletableFuture<Void> |
Fabric8FlinkKubeClient.createTaskManagerPod(KubernetesPod kubernetesPod) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKubeClient.PodCallbackHandler.onAdded(List<KubernetesPod> pods) |
void |
FlinkKubeClient.PodCallbackHandler.onDeleted(List<KubernetesPod> pods) |
void |
FlinkKubeClient.PodCallbackHandler.onError(List<KubernetesPod> pods) |
void |
FlinkKubeClient.PodCallbackHandler.onModified(List<KubernetesPod> pods) |
Modifier and Type | Method and Description |
---|---|
static KubernetesPod |
KubernetesTaskManagerFactory.buildTaskManagerKubernetesPod(KubernetesTaskManagerParameters kubernetesTaskManagerParameters) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.