Package org.apache.flink.runtime.util

Class HadoopConfigLoader

java.lang.Object

org.apache.flink.runtime.util.HadoopConfigLoader

public class HadoopConfigLoader
extends Object

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.conf.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 org.apache.hadoop.conf.Configuration getOrLoadHadoopConfig()

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