| 程序包 | 说明 |
|---|---|
| org.apache.flink.cdc.common.configuration | |
| org.apache.flink.cdc.common.factories | |
| org.apache.flink.cdc.common.udf |
| 限定符和类型 | 方法和说明 |
|---|---|
Configuration |
Configuration.clone() |
static Configuration |
Configuration.fromMap(Map<String,String> map)
Creates a new configuration that is initialized with the options of the given map.
|
<T> Configuration |
Configuration.set(ConfigOption<T> option,
T value) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
Configuration.addAll(Configuration other) |
| 构造器和说明 |
|---|
Configuration(Configuration other)
Creates a new configuration with the copy of the given configuration.
|
| 限定符和类型 | 方法和说明 |
|---|---|
Configuration |
Factory.Context.getFactoryConfiguration()
Returns the factory options used to create the object instances.
|
Configuration |
FactoryHelper.DefaultContext.getFactoryConfiguration() |
Configuration |
Factory.Context.getPipelineConfiguration()
Returns the configuration of current pipeline.
|
Configuration |
FactoryHelper.DefaultContext.getPipelineConfiguration() |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
FactoryHelper.validateFactoryOptions(Factory factory,
Configuration configuration)
Validates the required and optional
ConfigOptions of a factory. |
static void |
FactoryHelper.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions,
Set<ConfigOption<?>> optionalOptions,
Configuration configuration)
Validates the required options and optional options.
|
| 构造器和说明 |
|---|
DefaultContext(Configuration factoryConfiguration,
Configuration pipelineConfiguration,
ClassLoader classLoader) |
| 限定符和类型 | 方法和说明 |
|---|---|
Configuration |
UserDefinedFunctionContext.configuration() |
Copyright © 2025 The Apache Software Foundation. All rights reserved.