org.apache.paimon.options

Class OptionsUtils

java.lang.Object

org.apache.paimon.options.OptionsUtils

public class OptionsUtils
extends Object

Utility class for Options related helper functions.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PAIMON_PREFIX

Method Summary

Modifier and Type	Method and Description
static boolean	canBePrefixMap(ConfigOption<?> configOption) Maps can be represented in two ways.
static Map<String,String>	convertToDynamicTableProperties(Map<String,String> confData, String globalOptionKeyPrefix, Pattern tableOptionKeyPattern, int keyGroup)
static <E extends Enum<?>> E	convertToEnum(Object o, Class<E> clazz)
static Map<String,String>	convertToPropertiesPrefixKey(Iterable<Map.Entry<String,String>> confData, String prefixKey, java.util.function.Predicate<String> valuePredicate)
static Map<String,String>	convertToPropertiesPrefixKey(Map<String,String> confData, String prefixKey)
static <T> T	convertValue(Object rawValue, Class<?> clazz) Tries to convert the raw value into the provided type.
static boolean	filterPrefixMapKey(String key, String candidate) Filter condition for prefix map keys.

Methods inherited from class java.lang.Object

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

Field Detail

PAIMON_PREFIX

public static final String PAIMON_PREFIX

See Also:

Constant Field Values

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.

convertToPropertiesPrefixKey

public static Map<String,String> convertToPropertiesPrefixKey(Map<String,String> confData,
                                                              String prefixKey)

convertToPropertiesPrefixKey

public static Map<String,String> convertToPropertiesPrefixKey(Iterable<Map.Entry<String,String>> confData,
                                                              String prefixKey,
                                                              java.util.function.Predicate<String> valuePredicate)

convertToDynamicTableProperties

public static Map<String,String> convertToDynamicTableProperties(Map<String,String> confData,
                                                                 String globalOptionKeyPrefix,
                                                                 Pattern tableOptionKeyPattern,
                                                                 int keyGroup)