Class ExternalServiceDecorator
- java.lang.Object
-
- org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
-
- org.apache.flink.kubernetes.kubeclient.decorators.ExternalServiceDecorator
-
- All Implemented Interfaces:
KubernetesStepDecorator
public class ExternalServiceDecorator extends AbstractKubernetesStepDecorator
Creates an external Service to expose the rest port of the Flink JobManager(s).
-
-
Field Summary
-
Fields inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
logger
-
-
Constructor Summary
Constructors Constructor Description ExternalServiceDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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 StringgetExternalServiceName(String clusterId)Generate name of the external rest Service.static StringgetNamespacedExternalServiceName(String clusterId, String namespace)Generate namespaced name of the external rest Service by cluster Id, This is used by other project, so do not delete it.-
Methods inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
decorateFlinkPod
-
-
-
-
Constructor Detail
-
ExternalServiceDecorator
public ExternalServiceDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters)
-
-
Method Detail
-
buildAccompanyingKubernetesResources
public List<io.fabric8.kubernetes.api.model.HasMetadata> buildAccompanyingKubernetesResources() throws IOException
Description copied from class:AbstractKubernetesStepDecoratorNote that the method could have a side effect of modifying the Flink Configuration object, such as update the JobManager address.- Specified by:
buildAccompanyingKubernetesResourcesin interfaceKubernetesStepDecorator- Overrides:
buildAccompanyingKubernetesResourcesin classAbstractKubernetesStepDecorator- Throws:
IOException
-
getExternalServiceName
public static String getExternalServiceName(String clusterId)
Generate name of the external rest Service.
-
-