Class HadoopConfigLoader


  • public class HadoopConfigLoader
    extends Object
    This class lazily loads hadoop configuration from resettable Flink's configuration.
    • 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).