public class InternalServiceDecorator extends AbstractKubernetesStepDecorator
Constructor and Description |
---|
InternalServiceDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters) |
Modifier and Type | Method and Description |
---|---|
List<io.fabric8.kubernetes.api.model.HasMetadata> |
buildAccompanyingKubernetesResources()
Note that the method could have a side effect of modifying the Flink Configuration object,
such as update the JobManager address.
|
static String |
getInternalServiceName(String clusterId)
Generate name of the internal Service.
|
static String |
getNamespacedInternalServiceName(String clusterId,
String namespace)
Generate namespaced name of the internal Service.
|
decorateFlinkPod
public InternalServiceDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters)
public List<io.fabric8.kubernetes.api.model.HasMetadata> buildAccompanyingKubernetesResources() throws IOException
AbstractKubernetesStepDecorator
buildAccompanyingKubernetesResources
in interface KubernetesStepDecorator
buildAccompanyingKubernetesResources
in class AbstractKubernetesStepDecorator
IOException
public static String getInternalServiceName(String clusterId)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.