Package org.apache.flink.kubernetes.operator.config

Class FlinkConfigManager

  • public class FlinkConfigManager
extends java.lang.Object
    Configuration manager for the Flink operator.

    • Constructor Summary

      Constructors 
      Constructor Description
      FlinkConfigManager​(java.util.function.Consumer<java.util.Set<java.lang.String>> namespaceListener)  
      FlinkConfigManager​(org.apache.flink.configuration.Configuration defaultConfig)  
      FlinkConfigManager​(org.apache.flink.configuration.Configuration defaultConfig, java.util.function.Consumer<java.util.Set<java.lang.String>> namespaceListener)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected org.apache.flink.shaded.guava30.com.google.common.cache.Cache<org.apache.flink.kubernetes.operator.config.FlinkConfigManager.Key,​org.apache.flink.configuration.Configuration> getCache()  
      org.apache.flink.configuration.Configuration getDefaultConfig()  
      org.apache.flink.configuration.Configuration getDeployConfig​(io.fabric8.kubernetes.api.model.ObjectMeta objectMeta, org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec spec)  
      org.apache.flink.configuration.Configuration getObserveConfig​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)  
      FlinkOperatorConfiguration getOperatorConfiguration()  
      org.apache.flink.configuration.Configuration getSessionJobConfig​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment, org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec sessionJobSpec)  
      protected static org.apache.flink.configuration.Configuration loadGlobalConfiguration​(java.util.Optional<java.lang.String> confOverrideDir)  
      void updateDefaultConfig​(org.apache.flink.configuration.Configuration newConf)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • FlinkConfigManager

        @VisibleForTesting
public FlinkConfigManager​(org.apache.flink.configuration.Configuration defaultConfig)

      • FlinkConfigManager

        public FlinkConfigManager​(java.util.function.Consumer<java.util.Set<java.lang.String>> namespaceListener)

      • FlinkConfigManager

        public FlinkConfigManager​(org.apache.flink.configuration.Configuration defaultConfig,
                          java.util.function.Consumer<java.util.Set<java.lang.String>> namespaceListener)

    • Method Detail

      • getDefaultConfig

        public org.apache.flink.configuration.Configuration getDefaultConfig()

      • updateDefaultConfig

        @VisibleForTesting
public void updateDefaultConfig​(org.apache.flink.configuration.Configuration newConf)

      • getDeployConfig

        public org.apache.flink.configuration.Configuration getDeployConfig​(io.fabric8.kubernetes.api.model.ObjectMeta objectMeta,
                                                                    org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec spec)

      • getObserveConfig

        public org.apache.flink.configuration.Configuration getObserveConfig​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment)

      • getSessionJobConfig

        public org.apache.flink.configuration.Configuration getSessionJobConfig​(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment,
                                                                        org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec sessionJobSpec)

      • getCache

        @VisibleForTesting
protected org.apache.flink.shaded.guava30.com.google.common.cache.Cache<org.apache.flink.kubernetes.operator.config.FlinkConfigManager.Key,​org.apache.flink.configuration.Configuration> getCache()

      • loadGlobalConfiguration

        @VisibleForTesting
protected static org.apache.flink.configuration.Configuration loadGlobalConfiguration​(java.util.Optional<java.lang.String> confOverrideDir)