Package org.apache.flink.cdc.cli.utils

Class ConfigurationUtils

java.lang.Object

org.apache.flink.cdc.cli.utils.ConfigurationUtils

public class ConfigurationUtils
extends Object

Utilities for handling Configuration.

Constructor Summary

Constructors

Constructor	Description
ConfigurationUtils()

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	flattenConfigMap(Map<String,Object> config, String keyPrefix)
static Configuration	loadConfigFile(org.apache.flink.core.fs.Path configPath)
static Configuration	loadConfigFile(org.apache.flink.core.fs.Path configPath, boolean allowDuplicateKeys)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigurationUtils

public ConfigurationUtils()

Method Detail

loadConfigFile

public static Configuration loadConfigFile(org.apache.flink.core.fs.Path configPath)
                                    throws Exception

Throws:

Exception

loadConfigFile

public static Configuration loadConfigFile(org.apache.flink.core.fs.Path configPath,
                                           boolean allowDuplicateKeys)
                                    throws Exception

Throws:

Exception

flattenConfigMap

public static Map<String,String> flattenConfigMap(Map<String,Object> config,
                                                        String keyPrefix)