Uses of Class
org.apache.flink.cdc.common.configuration.Configuration

Packages that use Configuration

Package	Description
org.apache.flink.cdc.cli
org.apache.flink.cdc.cli.parser
org.apache.flink.cdc.cli.utils
org.apache.flink.cdc.common.configuration
org.apache.flink.cdc.common.factories
org.apache.flink.cdc.common.source.discover
org.apache.flink.cdc.common.udf
org.apache.flink.cdc.composer.definition
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.doris.sink
org.apache.flink.cdc.connectors.doris.utils
org.apache.flink.cdc.connectors.fluss.source
org.apache.flink.cdc.connectors.fluss.source.enumerator
org.apache.flink.cdc.connectors.hudi.sink
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.starrocks.sink

Uses of Configuration in org.apache.flink.cdc.cli

Methods in org.apache.flink.cdc.cli that return Configuration

Modifier and Type	Method	Description
Configuration	CliExecutor.getGlobalPipelineConfig()

Constructors in org.apache.flink.cdc.cli with parameters of type Configuration

Constructor	Description
CliExecutor(org.apache.commons.cli.CommandLine commandLine, org.apache.flink.core.fs.Path pipelineDefPath, org.apache.flink.configuration.Configuration flinkConfig, Configuration globalPipelineConfig, List<org.apache.flink.core.fs.Path> additionalJars, org.apache.flink.core.fs.Path flinkHome)

Uses of Configuration in org.apache.flink.cdc.cli.parser

Methods in org.apache.flink.cdc.cli.parser with parameters of type Configuration

Modifier and Type	Method	Description
PipelineDef	PipelineDefinitionParser.parse(String pipelineDefText, Configuration globalPipelineConfig)	Parse the specified pipeline definition string, merge global configurations, then generate the PipelineDef.
PipelineDef	PipelineDefinitionParser.parse(org.apache.flink.core.fs.Path pipelineDefPath, Configuration globalPipelineConfig)	Parse the specified pipeline definition file path, merge global configurations, then generate the PipelineDef.
PipelineDef	YamlPipelineDefinitionParser.parse(String pipelineDefText, Configuration globalPipelineConfig)
PipelineDef	YamlPipelineDefinitionParser.parse(org.apache.flink.core.fs.Path pipelineDefPath, Configuration globalPipelineConfig)	Parse the specified pipeline definition file.

Uses of Configuration in org.apache.flink.cdc.cli.utils

Methods in org.apache.flink.cdc.cli.utils that return Configuration

Modifier and Type	Method	Description
static Configuration	ConfigurationUtils.loadConfigFile(org.apache.flink.core.fs.Path configPath)
static Configuration	ConfigurationUtils.loadConfigFile(org.apache.flink.core.fs.Path configPath, boolean allowDuplicateKeys)

Uses of Configuration in org.apache.flink.cdc.common.configuration

Methods in org.apache.flink.cdc.common.configuration that return Configuration

Modifier and Type	Method	Description
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)

Methods in org.apache.flink.cdc.common.configuration with parameters of type Configuration

Modifier and Type	Method	Description
void	Configuration.addAll(Configuration other)

Constructors in org.apache.flink.cdc.common.configuration with parameters of type Configuration

Constructor	Description
Configuration(Configuration other)	Creates a new configuration with the copy of the given configuration.

Uses of Configuration in org.apache.flink.cdc.common.factories

Methods in org.apache.flink.cdc.common.factories that return Configuration

Modifier and Type	Method	Description
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()

Methods in org.apache.flink.cdc.common.factories with parameters of type Configuration

Modifier and Type	Method	Description
static void	FactoryHelper.validateFactoryOptions(Set<ConfigOption<?>> requiredOptions, Set<ConfigOption<?>> optionalOptions, Configuration configuration)	Validates the required options and optional options.
static void	FactoryHelper.validateFactoryOptions(Factory factory, Configuration configuration)	Validates the required and optional ConfigOptions of a factory.

Constructors in org.apache.flink.cdc.common.factories with parameters of type Configuration

Constructor	Description
DefaultContext(Configuration factoryConfiguration, Configuration pipelineConfiguration, ClassLoader classLoader)
DefaultContext(Configuration factoryConfiguration, Configuration pipelineConfiguration, ClassLoader classLoader, org.apache.flink.configuration.ReadableConfig flinkConf)

Uses of Configuration in org.apache.flink.cdc.common.source.discover

Methods in org.apache.flink.cdc.common.source.discover that return Configuration

Modifier and Type	Method	Description
Configuration	ObjectIdDiscoverer.Context.getConfiguration()	Returns the full connector configuration.
Configuration	ObjectIdDiscovererFactory.DefaultObjectIdDiscovererContext.getConfiguration()

Methods in org.apache.flink.cdc.common.source.discover with parameters of type Configuration

Modifier and Type	Method	Description
static ObjectIdDiscoverer.Context	ObjectIdDiscovererFactory.createContext(Configuration configuration, ClassLoader classLoader)	Creates a discoverer context with the given configuration and class loader.
static ObjectIdDiscoverer.Context	TableDiscovererFactory.createContext(Configuration configuration, ClassLoader classLoader)	Creates a discoverer context with the given configuration and class loader.

Uses of Configuration in org.apache.flink.cdc.common.udf

Methods in org.apache.flink.cdc.common.udf that return Configuration

Modifier and Type	Method	Description
Configuration	UserDefinedFunctionContext.configuration()

Uses of Configuration in org.apache.flink.cdc.composer.definition

Methods in org.apache.flink.cdc.composer.definition that return Configuration

Modifier and Type	Method	Description
Configuration	PipelineDef.getConfig()
Configuration	SinkDef.getConfig()
Configuration	SourceDef.getConfig()

Constructors in org.apache.flink.cdc.composer.definition with parameters of type Configuration

Constructor	Description
PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, List<ModelDef> models, Configuration config)
PipelineDef(SourceDef source, SinkDef sink, List<RouteDef> routes, List<TransformDef> transforms, List<UdfDef> udfs, Configuration config)
SinkDef(String type, String name, Configuration config)
SinkDef(String type, String name, Configuration config, Set<SchemaChangeEventType> includedSchemaEvolutionTypes)
SinkDef(String type, String name, Configuration config, Set<SchemaChangeEventType> includedSchemaEvolutionTypes, ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode)
SourceDef(String type, String name, Configuration config)

Uses of Configuration in org.apache.flink.cdc.composer.flink.translator

Methods in org.apache.flink.cdc.composer.flink.translator with parameters of type Configuration

Modifier and Type	Method	Description
DataSink	DataSinkTranslator.createDataSink(SinkDef sinkDef, Configuration pipelineConfig, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
DataSource	DataSourceTranslator.createDataSource(SourceDef sourceDef, Configuration pipelineConfig, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Uses of Configuration in org.apache.flink.cdc.connectors.doris.sink

Fields in org.apache.flink.cdc.connectors.doris.sink declared as Configuration

Modifier and Type	Field	Description
Configuration	DorisEventSerializer.dorisConfig

Methods in org.apache.flink.cdc.connectors.doris.sink with parameters of type Configuration

Modifier and Type	Method	Description
static Map<String,String>	DorisDataSinkOptions.getPropertiesByPrefix(Configuration tableOptions, String prefix)

Constructors in org.apache.flink.cdc.connectors.doris.sink with parameters of type Configuration

Constructor	Description
DorisDataSink(org.apache.doris.flink.cfg.DorisOptions dorisOptions, org.apache.doris.flink.cfg.DorisReadOptions dorisReadOptions, org.apache.doris.flink.cfg.DorisExecutionOptions dorisExecutionOptions, Configuration configuration, java.time.ZoneId zoneId)
DorisEventSerializer(java.time.ZoneId zoneId, Configuration config)
DorisMetadataApplier(org.apache.doris.flink.cfg.DorisOptions dorisOptions, Configuration config)

Uses of Configuration in org.apache.flink.cdc.connectors.doris.utils

Methods in org.apache.flink.cdc.connectors.doris.utils with parameters of type Configuration

Modifier and Type	Method	Description
static org.apache.flink.api.java.tuple.Tuple2<String,String>	DorisSchemaUtils.getPartitionInfo(Configuration config, Schema schema, TableId tableId)	Get partition info by config.

Uses of Configuration in org.apache.flink.cdc.connectors.fluss.source

Constructors in org.apache.flink.cdc.connectors.fluss.source with parameters of type Configuration

Constructor	Description
FlussDataSource(org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, TableDiscoverer discoverer, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs)
FlussSource(TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, FlussDeserializer<T> deserializer)

Uses of Configuration in org.apache.flink.cdc.connectors.fluss.source.enumerator

Constructors in org.apache.flink.cdc.connectors.fluss.source.enumerator with parameters of type Configuration

Constructor	Description
FlussSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> context, TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, Set<org.apache.fluss.metadata.PhysicalTablePath> assignedPhysicalTablePaths, List<FlussSplitBase> remainingSplits, LeaseContext leaseContext, boolean checkpointCompletedBefore)
FlussSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> context, TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, FlussSourceEnumState restoredState, LeaseContext leaseContext)

Uses of Configuration in org.apache.flink.cdc.connectors.hudi.sink

Constructors in org.apache.flink.cdc.connectors.hudi.sink with parameters of type Configuration

Constructor	Description
HudiDataSink(Configuration config, String schemaOperatorUid)
HudiMetadataApplier(Configuration config)

Uses of Configuration in org.apache.flink.cdc.connectors.oracle.source

Methods in org.apache.flink.cdc.connectors.oracle.source with parameters of type Configuration

Modifier and Type	Method	Description
static Map<String,String>	OracleDataSourceOptions.getPropertiesByPrefix(Configuration tableOptions, String prefix)

Constructors in org.apache.flink.cdc.connectors.oracle.source with parameters of type Configuration

Constructor	Description
OracleDataSource(OracleSourceConfigFactory configFactory, Configuration config, List<OracleReadableMetaData> readableMetadataList)

Uses of Configuration in org.apache.flink.cdc.connectors.starrocks.sink

Methods in org.apache.flink.cdc.connectors.starrocks.sink with parameters of type Configuration

Modifier and Type	Method	Description
static SchemaChangeConfig	SchemaChangeConfig.from(Configuration config)
static TableCreateConfig	TableCreateConfig.from(Configuration config)