org.apache.flink.runtime.fs.hdfs

Class HadoopConfigLoader

java.lang.Object

org.apache.flink.runtime.fs.hdfs.HadoopConfigLoader

public class HadoopConfigLoader
extends Object

This class lazily loads hadoop configuration from resettable Flink's configuration.

Constructor Summary

Constructors

Constructor and Description
HadoopConfigLoader(String[] flinkConfigPrefixes, String[][] mirroredConfigKeys, String hadoopConfigPrefix, Set<String> packagePrefixesToShade, Set<String> configKeysToShade, String flinkShadingPrefix)

Method Summary

Modifier and Type	Method and Description
Configuration	getOrLoadHadoopConfig() get the loaded Hadoop config (or fall back to one loaded from the classpath).
void	setFlinkConfig(Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopConfigLoader

public HadoopConfigLoader(@Nonnull
                          String[] flinkConfigPrefixes,
                          @Nonnull
                          String[][] mirroredConfigKeys,
                          @Nonnull
                          String hadoopConfigPrefix,
                          Set<String> packagePrefixesToShade,
                          @Nonnull
                          Set<String> configKeysToShade,
                          @Nonnull
                          String flinkShadingPrefix)

Method Detail

setFlinkConfig

public void setFlinkConfig(Configuration config)

getOrLoadHadoopConfig

public Configuration getOrLoadHadoopConfig()

get the loaded Hadoop config (or fall back to one loaded from the classpath).