org.apache.flink.runtime.clusterframework.overlays

Class HadoopConfOverlay

java.lang.Object

org.apache.flink.runtime.clusterframework.overlays.HadoopConfOverlay

All Implemented Interfaces:

ContainerOverlay

public class HadoopConfOverlay
extends Object
implements ContainerOverlay

Overlays a Hadoop configuration into a container, based on a supplied Hadoop configuration directory. The following files are copied to the container: - hadoop/conf/core-site.xml - hadoop/conf/hdfs-site.xml The following environment variables are set in the container: - HADOOP_CONF_DIR The following Flink configuration entries are updated: - fs.hdfs.hadoopconf

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HadoopConfOverlay.Builder A builder for the HadoopConfOverlay.

Constructor Summary

Constructors

Constructor and Description
HadoopConfOverlay(File hadoopConfDir)

Method Summary

Modifier and Type	Method and Description
void	configure(ContainerSpecification container) Configure the given container specification.
static HadoopConfOverlay.Builder	newBuilder()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopConfOverlay

public HadoopConfOverlay(@Nullable
                         File hadoopConfDir)

Method Detail

configure

public void configure(ContainerSpecification container)
               throws IOException

Description copied from interface: ContainerOverlay

Configure the given container specification.

Specified by:

configure in interface ContainerOverlay

Throws:

IOException

newBuilder

public static HadoopConfOverlay.Builder newBuilder()