public class InitJobManagerDecorator extends AbstractKubernetesStepDecorator
FlinkPod.| Constructor and Description |
|---|
InitJobManagerDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters) |
| Modifier and Type | Method and Description |
|---|---|
FlinkPod |
decorateFlinkPod(FlinkPod flinkPod)
Apply transformations on the given FlinkPod in accordance to this feature.
|
buildAccompanyingKubernetesResourcespublic InitJobManagerDecorator(KubernetesJobManagerParameters kubernetesJobManagerParameters)
public FlinkPod decorateFlinkPod(FlinkPod flinkPod)
AbstractKubernetesStepDecoratorSo 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()
decorateFlinkPod in interface KubernetesStepDecoratordecorateFlinkPod in class AbstractKubernetesStepDecoratorCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.