Interface KubernetesStepDecorator
-
- All Known Implementing Classes:
AbstractKubernetesStepDecorator,CmdJobManagerDecorator,CmdTaskManagerDecorator,EnvSecretsDecorator,ExternalServiceDecorator,FlinkConfMountDecorator,HadoopConfMountDecorator,InitJobManagerDecorator,InitTaskManagerDecorator,InternalServiceDecorator,KerberosMountDecorator,MountSecretsDecorator,PodTemplateMountDecorator
public interface KubernetesStepDecoratorA 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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description List<io.fabric8.kubernetes.api.model.HasMetadata>buildAccompanyingKubernetesResources()Build the accompanying Kubernetes resources that should be introduced to support this feature.FlinkPoddecorateFlinkPod(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
-
-