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
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.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
-
-