class FlinkDistributionOverlay extends AbstractContainerOverlay {

	@Override
	public void configure(ContainerSpecification container) throws IOException {

		container.getEnvironmentVariables().put(ENV_FLINK_HOME_DIR, TARGET_ROOT.toString());

		// add the paths to the container specification.
		addPathRecursively(flinkBinPath, TARGET_ROOT, container);
		addPathRecursively(flinkConfPath, TARGET_ROOT, container);
		addPathRecursively(flinkLibPath, TARGET_ROOT, container);
		if (flinkPluginsPath.isDirectory()) {
			addPathRecursively(flinkPluginsPath, TARGET_ROOT, container);
		}
		else {
			LOG.warn("The plugins directory '" + flinkPluginsPath + "' doesn't exist.");
		}
	}

	public  FlinkDistributionOverlay(File flinkBinPath, File flinkConfPath, File flinkLibPath, File flinkPluginsPath);

}