org.apache.flink.kubernetes.kubeclient.decorators

Interface KubernetesStepDecorator

All Known Implementing Classes:

AbstractKubernetesStepDecorator, CmdJobManagerDecorator, CmdTaskManagerDecorator, EnvSecretsDecorator, ExternalServiceDecorator, FlinkConfMountDecorator, HadoopConfMountDecorator, InitJobManagerDecorator, InitTaskManagerDecorator, InternalServiceDecorator, KerberosMountDecorator, MountSecretsDecorator, PodTemplateMountDecorator

public interface KubernetesStepDecorator

A set of functions that together represent a feature in pods that are deployed for the JobManager(s) or the TaskManager(s), which provides an extension to the way the given Flink application works.

Method Summary

Modifier and Type	Method and Description
List<io.fabric8.kubernetes.api.model.HasMetadata>	buildAccompanyingKubernetesResources() Build the accompanying Kubernetes resources that should be introduced to support this feature.
FlinkPod	decorateFlinkPod(FlinkPod flinkPod) Apply transformations to the given FlinkPod in accordance with this feature.

Method Detail

decorateFlinkPod

FlinkPod decorateFlinkPod(FlinkPod flinkPod)

Apply transformations to the given FlinkPod in accordance with this feature. This can include adding labels/annotations, mounting volumes, and setting startup command or parameters, etc.

buildAccompanyingKubernetesResources

List<io.fabric8.kubernetes.api.model.HasMetadata> buildAccompanyingKubernetesResources()
                                                                                throws IOException

Build the accompanying Kubernetes resources that should be introduced to support this feature. This could only be applicable on the client-side submission process.

Throws:

IOException