Class FlinkConfigManager


  • public class FlinkConfigManager
    extends java.lang.Object
    Configuration manager for the Flink operator.
    • 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,
                                                                            FlinkDeploymentSpec spec)
      • getObserveConfig

        public org.apache.flink.configuration.Configuration getObserveConfig​(FlinkDeployment deployment)
      • 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)