class FlinkConfMountDecorator extends AbstractKubernetesStepDecorator {

	@Override
	public FlinkPod decorateFlinkPod(FlinkPod flinkPod) {
		final Pod mountedPod = decoratePod(flinkPod.getPod());

		final Container mountedMainContainer = new ContainerBuilder(flinkPod.getMainContainer())
			.addNewVolumeMount()
				.withName(FLINK_CONF_VOLUME)
				.withMountPath(kubernetesComponentConf.getFlinkConfDirInPod())
				.endVolumeMount()
			.build();

		return new FlinkPod.Builder(flinkPod)
			.withPod(mountedPod)
			.withMainContainer(mountedMainContainer)
			.build();
	}

	public  FlinkConfMountDecorator(AbstractKubernetesParameters kubernetesComponentConf);

}