Class MountSecretsDecorator
- java.lang.Object
-
- org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
-
- org.apache.flink.kubernetes.kubeclient.decorators.MountSecretsDecorator
-
- All Implemented Interfaces:
KubernetesStepDecorator
public class MountSecretsDecorator extends AbstractKubernetesStepDecorator
Support mounting Secrets on the JobManager or TaskManager pod..
-
-
Field Summary
-
Fields inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
logger
-
-
Constructor Summary
Constructors Constructor Description MountSecretsDecorator(AbstractKubernetesParameters kubernetesComponentConf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FlinkPoddecorateFlinkPod(FlinkPod flinkPod)Apply transformations on the given FlinkPod in accordance to this feature.-
Methods inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator
buildAccompanyingKubernetesResources
-
-
-
-
Constructor Detail
-
MountSecretsDecorator
public MountSecretsDecorator(AbstractKubernetesParameters kubernetesComponentConf)
-
-
Method Detail
-
decorateFlinkPod
public FlinkPod decorateFlinkPod(FlinkPod flinkPod)
Description copied from class:AbstractKubernetesStepDecoratorApply transformations on the given FlinkPod in accordance to this feature. Note that we should return a FlinkPod that keeps all of the properties of the passed FlinkPod object.So this is correct:
Pod decoratedPod = new PodBuilder(pod) // Keeps the original state ... .build() Container decoratedContainer = new ContainerBuilder(container) // Keeps the original state ... .build() FlinkPod decoratedFlinkPod = new FlinkPodBuilder(flinkPod) // Keeps the original state ... .build()And this is the incorrect:
Pod decoratedPod = new PodBuilder() // Loses the original state ... .build() Container decoratedContainer = new ContainerBuilder() // Loses the original state ... .build() FlinkPod decoratedFlinkPod = new FlinkPodBuilder() // Loses the original state ... .build()- Specified by:
decorateFlinkPodin interfaceKubernetesStepDecorator- Overrides:
decorateFlinkPodin classAbstractKubernetesStepDecorator
-
-