Package org.apache.flink.cdc.common.configuration

Class ConfigurationUtils

  • public class ConfigurationUtils
extends Object
    Utility class for Configuration related helper functions.

    • Method Detail

      • convertValue

        public static <T> T convertValue​(Object rawValue,
                                 Class<?> clazz)
        Tries to convert the raw value into the provided type.
        Type Parameters:
        T - type of the result
        Parameters:
        rawValue - rawValue to convert into the provided type clazz
        clazz - clazz specifying the target type
        Returns:
        the converted value if rawValue is of type clazz
        Throws:
        IllegalArgumentException - if the rawValue cannot be converted in the specified target type clazz

      • convertToEnum

        public static <E extends Enum<?>> E convertToEnum​(Object o,
                                                  Class<E> clazz)

      • canBePrefixMap

        public static boolean canBePrefixMap​(ConfigOption<?> configOption)
        Maps can be represented in two ways.

        With constant key space: 

             avro-confluent.properties = schema: 1, other-prop: 2

        Or with variable key space (i.e. prefix notation): 

             avro-confluent.properties.schema = 1
     avro-confluent.properties.other-prop = 2

      • filterPrefixMapKey

        public static boolean filterPrefixMapKey​(String key,
                                         String candidate)
        Filter condition for prefix map keys.