Package org.apache.flink.kubernetes.operator.utils

Class ConfigOptionUtils

  • public class ConfigOptionUtils
extends java.lang.Object
    ConfigOption utilities.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <T extends java.lang.Comparable<T>>
      T      		 getValueWithThreshold​(org.apache.flink.configuration.Configuration config, org.apache.flink.configuration.ConfigOption<T> configOption, T configThreshold)
      Gets the value of ConfigOption with threshold.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • ConfigOptionUtils

        public ConfigOptionUtils()

    • Method Detail

      • getValueWithThreshold

        public static <T extends java.lang.Comparable<T>> T getValueWithThreshold​(org.apache.flink.configuration.Configuration config,
                                                                          org.apache.flink.configuration.ConfigOption<T> configOption,
                                                                          T configThreshold)
        Gets the value of ConfigOption with threshold.
        Type Parameters:
        T - Type of the config value.
        Parameters:
        config - The effective config
        configOption - The config option.
        configThreshold - The config threshold.
        Returns:
        The value of ConfigOption with threshold.