Package | Description |
---|---|
org.apache.flink.kubernetes.kubeclient |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<KubernetesService> |
FlinkKubeClient.createInternalService(String clusterId)
Create kubernetes service for internal use.
|
CompletableFuture<KubernetesService> |
Fabric8FlinkKubeClient.createInternalService(String clusterId) |
CompletableFuture<KubernetesService> |
FlinkKubeClient.createRestService(String clusterId)
Create kubernetes service for rest port.
|
CompletableFuture<KubernetesService> |
Fabric8FlinkKubeClient.createRestService(String clusterId) |
Optional<KubernetesService> |
FlinkKubeClient.getInternalService(String clusterId)
Get the kubernetes internal service of the given flink clusterId.
|
Optional<KubernetesService> |
Fabric8FlinkKubeClient.getInternalService(String clusterId) |
Optional<KubernetesService> |
FlinkKubeClient.getRestService(String clusterId)
Get the kubernetes rest service of the given flink clusterId.
|
Optional<KubernetesService> |
Fabric8FlinkKubeClient.getRestService(String clusterId) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.