Package | Description |
---|---|
org.apache.flink.kubernetes.kubeclient | |
org.apache.flink.kubernetes.kubeclient.resources |
Modifier and Type | Method and Description |
---|---|
Optional<KubernetesService> |
Fabric8FlinkKubeClient.getService(KubernetesService.ServiceType serviceType,
String clusterId) |
Optional<KubernetesService> |
FlinkKubeClient.getService(KubernetesService.ServiceType serviceType,
String clusterId)
Get the kubernetes service of the given flink clusterId.
|
CompletableFuture<Void> |
Fabric8FlinkKubeClient.updateServiceTargetPort(KubernetesService.ServiceType serviceType,
String clusterId,
String portName,
int targetPort) |
CompletableFuture<Void> |
FlinkKubeClient.updateServiceTargetPort(KubernetesService.ServiceType serviceType,
String clusterId,
String portName,
int targetPort)
Update the target ports of the given Kubernetes service.
|
Modifier and Type | Method and Description |
---|---|
static KubernetesService.ServiceType |
KubernetesService.ServiceType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static KubernetesService.ServiceType[] |
KubernetesService.ServiceType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.