public class InitTaskManagerDecorator extends AbstractKubernetesStepDecorator
FlinkPod
.logger
Constructor and Description |
---|
InitTaskManagerDecorator(KubernetesTaskManagerParameters kubernetesTaskManagerParameters) |
Modifier and Type | Method and Description |
---|---|
FlinkPod |
decorateFlinkPod(FlinkPod flinkPod)
Apply transformations on the given FlinkPod in accordance to this feature.
|
buildAccompanyingKubernetesResources
public InitTaskManagerDecorator(KubernetesTaskManagerParameters kubernetesTaskManagerParameters)
public FlinkPod decorateFlinkPod(FlinkPod flinkPod)
AbstractKubernetesStepDecorator
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()
decorateFlinkPod
in interface KubernetesStepDecorator
decorateFlinkPod
in class AbstractKubernetesStepDecorator
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.