类的使用
org.apache.flink.cdc.common.configuration.ConfigOption

使用ConfigOption的程序包

程序包	说明
org.apache.flink.cdc.common.configuration
org.apache.flink.cdc.common.factories
org.apache.flink.cdc.common.pipeline

org.apache.flink.cdc.common.configuration中ConfigOption的使用

返回ConfigOption的org.apache.flink.cdc.common.configuration中的方法

限定符和类型	方法和说明
ConfigOption<T>	ConfigOptions.TypedConfigOptionBuilder.defaultValue(T value) Creates a ConfigOption with the given default value.
ConfigOption<List<E>>	ConfigOptions.ListConfigOptionBuilder.defaultValues(E... values) Creates a ConfigOption with the given default value.
ConfigOption<T>	ConfigOptions.TypedConfigOptionBuilder.noDefaultValue() Creates a ConfigOption without a default value.
ConfigOption<List<E>>	ConfigOptions.ListConfigOptionBuilder.noDefaultValue() Creates a ConfigOption without a default value.
ConfigOption<T>	ConfigOption.withDeprecatedKeys(String... deprecatedKeys) Creates a new config option, using this option's key and default value, and adding the given deprecated keys.
ConfigOption<T>	ConfigOption.withDescription(Description description) Creates a new config option, using this option's key and default value, and adding the given description.
ConfigOption<T>	ConfigOption.withDescription(String description) Creates a new config option, using this option's key and default value, and adding the given description.
ConfigOption<T>	ConfigOption.withFallbackKeys(String... fallbackKeys) Creates a new config option, using this option's key and default value, and adding the given fallback keys.

参数类型为ConfigOption的org.apache.flink.cdc.common.configuration中的方法

限定符和类型	方法和说明
static boolean	ConfigurationUtils.canBePrefixMap(ConfigOption<?> configOption) Maps can be represented in two ways.
boolean	Configuration.contains(ConfigOption<?> configOption) Checks whether there is an entry for the given config option.
<T> T	Configuration.get(ConfigOption<T> option)
<T> Optional<T>	Configuration.getOptional(ConfigOption<T> option)
<T> boolean	Configuration.remove(ConfigOption<T> configOption) Removes given config option from the configuration.
<T> Configuration	Configuration.set(ConfigOption<T> option, T value)

org.apache.flink.cdc.common.factories中ConfigOption的使用

返回变量类型为ConfigOption的类型的org.apache.flink.cdc.common.factories中的方法

限定符和类型	方法和说明
Set<ConfigOption<?>>	Factory.optionalOptions() Returns a set of ConfigOption that an implementation of this factory consumes in addition to Factory.requiredOptions().
Set<ConfigOption<?>>	Factory.requiredOptions() Returns a set of ConfigOption that an implementation of this factory requires in addition to Factory.optionalOptions().

类型变量类型为ConfigOption的org.apache.flink.cdc.common.factories中的方法参数

限定符和类型	方法和说明
static void	FactoryHelper.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, Configuration configuration) Validates the required options and optional options.
static void	FactoryHelper.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, Configuration configuration) Validates the required options and optional options.

org.apache.flink.cdc.common.pipeline中ConfigOption的使用

声明为ConfigOption的org.apache.flink.cdc.common.pipeline中的字段

限定符和类型	字段和说明
static ConfigOption<String>	PipelineOptions.PIPELINE_LOCAL_TIME_ZONE
static ConfigOption<String>	PipelineOptions.PIPELINE_NAME
static ConfigOption<Integer>	PipelineOptions.PIPELINE_PARALLELISM
static ConfigOption<SchemaChangeBehavior>	PipelineOptions.PIPELINE_SCHEMA_CHANGE_BEHAVIOR
static ConfigOption<java.time.Duration>	PipelineOptions.PIPELINE_SCHEMA_OPERATOR_RPC_TIMEOUT
static ConfigOption<String>	PipelineOptions.PIPELINE_SCHEMA_OPERATOR_UID