Interface KubernetesStepDecorator

    • 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