InternalServiceDecorator (Flink : Kubernetes 1.18.1-cp7 API)

java.lang.Object
- org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
- - org.apache.flink.kubernetes.kubeclient.decorators.InternalServiceDecorator

All Implemented Interfaces:

KubernetesStepDecorator
```
public class InternalServiceDecorator
extends AbstractKubernetesStepDecorator
```
Creates an internal Service which forwards the requests from the TaskManager(s) to the active JobManager. Note that only the non-HA scenario relies on this Service for internal communication, since in the HA mode, the TaskManager(s) directly connects to the JobManager via IP address.

Field Summary
- Fields inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
  logger

Constructor Summary

Constructors
Constructor Description

InternalServiceDecorator(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 String`	`getInternalServiceName(String clusterId)`	Generate name of the internal Service.
`static String`	`getNamespacedInternalServiceName(String clusterId, String namespace)`	Generate namespaced name of the internal Service.

Methods inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
decorateFlinkPod

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - InternalServiceDecorator
```
public InternalServiceDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters)
```
- Method Detail
  - buildAccompanyingKubernetesResources
```
public List<io.fabric8.kubernetes.api.model.HasMetadata> buildAccompanyingKubernetesResources()
                                                                                       throws IOException
```
    Description copied from class: AbstractKubernetesStepDecorator
    
    Note that the method could have a side effect of modifying the Flink Configuration object, such as update the JobManager address.
    
    Specified by:
    
    buildAccompanyingKubernetesResources in interface KubernetesStepDecorator
    
    Overrides:
    
    buildAccompanyingKubernetesResources in class AbstractKubernetesStepDecorator
    
    Throws:
    
    IOException
  - getInternalServiceName
```
public static String getInternalServiceName(String clusterId)
```
    Generate name of the internal Service.
  - getNamespacedInternalServiceName
```
public static String getNamespacedInternalServiceName(String clusterId,
                                                      String namespace)
```
    Generate namespaced name of the internal Service.