Uses of Class
org.apache.flink.cdc.common.annotation.Experimental

Packages that use Experimental

Package	Description
org.apache.flink.cdc.common.model
org.apache.flink.cdc.common.model.abilities
org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source
org.apache.flink.cdc.connectors.base.config
org.apache.flink.cdc.connectors.base.dialect
org.apache.flink.cdc.connectors.base.options
org.apache.flink.cdc.connectors.base.relational.connection
org.apache.flink.cdc.connectors.base.relational.handler
org.apache.flink.cdc.connectors.base.source
org.apache.flink.cdc.connectors.base.source.assigner
org.apache.flink.cdc.connectors.base.source.assigner.splitter
org.apache.flink.cdc.connectors.base.source.enumerator
org.apache.flink.cdc.connectors.base.source.meta.offset
org.apache.flink.cdc.connectors.base.source.meta.split
org.apache.flink.cdc.connectors.base.source.reader
org.apache.flink.cdc.connectors.base.source.reader.external
org.apache.flink.cdc.connectors.db2.source.dialect
org.apache.flink.cdc.connectors.iceberg.sink
org.apache.flink.cdc.connectors.mongodb.source
org.apache.flink.cdc.connectors.mongodb.source.assigners.splitters
org.apache.flink.cdc.connectors.mongodb.source.config
org.apache.flink.cdc.connectors.mongodb.source.dialect
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.config
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.reader
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.source.dialect
org.apache.flink.cdc.python
org.apache.flink.cdc.runtime.operators.transform.converter

Uses of Experimental in org.apache.flink.cdc.common.model

Classes in org.apache.flink.cdc.common.model with annotations of type Experimental

Modifier and Type	Interface	Description
interface	AiModelClient	Marker interface for a runtime AI model client.
interface	AiModelClientFactory	A Factory that creates AiModelClient instances.
interface	ModelContext	Context passed to AiModelClientFactory.createClient(org.apache.flink.cdc.common.model.ModelContext) at pipeline assembly time.

Uses of Experimental in org.apache.flink.cdc.common.model.abilities

Classes in org.apache.flink.cdc.common.model.abilities with annotations of type Experimental

Modifier and Type	Interface	Description
interface	SupportsEmbedding	Ability interface for AiModelClient implementations that can produce dense vector embeddings from text input.
interface	SupportsImageEmbedding	Ability interface for AiModelClient implementations that can embed image bytes.
interface	SupportsImageTextGeneration	Ability interface for AiModelClient implementations that can generate text from an image combined with a natural-language prompt.
interface	SupportsTextGeneration	Ability interface for AiModelClient implementations that can perform chat-style text generation given a system prompt and a user input.

Uses of Experimental in org.apache.flink.cdc.common.pipeline

Classes in org.apache.flink.cdc.common.pipeline with annotations of type Experimental

Modifier and Type	Class	Description
class	ExistingTableSchemaExpansionMode	Strategy for handling an existing target table when the initial CreateTableEvent arrives.

Uses of Experimental in org.apache.flink.cdc.common.sink

Classes in org.apache.flink.cdc.common.sink with annotations of type Experimental

Modifier and Type	Interface	Description
interface	ExistingTableSchemaExpansionSupport	Connector-specific capabilities required to safely expand an existing target table schema.

Methods in org.apache.flink.cdc.common.sink with annotations of type Experimental

Modifier and Type	Method	Description
default Optional<ExistingTableSchemaExpansionSupport>	MetadataApplier.getExistingTableSchemaExpansionSupport()	Returns optional support for safely expanding an existing target table schema.

Uses of Experimental in org.apache.flink.cdc.common.source

Classes in org.apache.flink.cdc.common.source with annotations of type Experimental

Modifier and Type	Interface	Description
interface	SupportedMetadataColumn	A metadata column that the source supports to read from the meta field.

Methods in org.apache.flink.cdc.common.source with annotations of type Experimental

Modifier and Type	Method	Description
default boolean	DataSource.isParallelMetadataSource()	Indicating if this source may generate metadata events (SchemaChangeEvents) in parallel for each table.

Uses of Experimental in org.apache.flink.cdc.connectors.base.config

Classes in org.apache.flink.cdc.connectors.base.config with annotations of type Experimental

Modifier and Type	Interface	Description
interface	SourceConfig	The source configuration which offers basic source configuration.

Uses of Experimental in org.apache.flink.cdc.connectors.base.dialect

Classes in org.apache.flink.cdc.connectors.base.dialect with annotations of type Experimental

Modifier and Type	Interface	Description
interface	DataSourceDialect<C extends SourceConfig>	The dialect of data source.
interface	JdbcDataSourceDialect	The dialect of JDBC data source.

Uses of Experimental in org.apache.flink.cdc.connectors.base.options

Fields in org.apache.flink.cdc.connectors.base.options with annotations of type Experimental

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Boolean>	SourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static org.apache.flink.configuration.ConfigOption<Boolean>	SourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SourceOptions.SCAN_READ_CHANGELOG_AS_APPEND_ONLY_ENABLED

Uses of Experimental in org.apache.flink.cdc.connectors.base.relational.connection

Classes in org.apache.flink.cdc.connectors.base.relational.connection with annotations of type Experimental

Modifier and Type	Interface	Description
interface	ConnectionPools<P,C extends SourceConfig>	A pool collection that consists of multiple connection pools.

Uses of Experimental in org.apache.flink.cdc.connectors.base.relational.handler

Classes in org.apache.flink.cdc.connectors.base.relational.handler with annotations of type Experimental

Modifier and Type	Interface	Description
interface	SchemaChangeEventHandler	This handler helps to parse the source struct in SchemaChangeEvent and generate source info.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source

Classes in org.apache.flink.cdc.connectors.base.source with annotations of type Experimental

Modifier and Type	Class	Description
class	IncrementalSource<T,C extends SourceConfig>	The basic source of Incremental Snapshot framework for datasource, it is based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change by streaming reading.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.assigner

Classes in org.apache.flink.cdc.connectors.base.source.assigner with annotations of type Experimental

Modifier and Type	Interface	Description
interface	SplitAssigner	The SplitAssigner is responsible for deciding what split should be processed.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.assigner.splitter

Classes in org.apache.flink.cdc.connectors.base.source.assigner.splitter with annotations of type Experimental

Modifier and Type	Interface	Description
interface	ChunkSplitter	The splitter used to split collection into a set of chunks.
class	JdbcSourceChunkSplitter	The ChunkSplitter used to split table into a set of chunks for JDBC data source.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.enumerator

Classes in org.apache.flink.cdc.connectors.base.source.enumerator with annotations of type Experimental

Modifier and Type	Class	Description
class	IncrementalSourceEnumerator	Incremental source enumerator that enumerates receive the split request and assign the split to source readers.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.meta.offset

Classes in org.apache.flink.cdc.connectors.base.source.meta.offset with annotations of type Experimental

Modifier and Type	Class	Description
class	Offset	A structure describes a fine-grained offset in a change event including change log position.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.meta.split

Classes in org.apache.flink.cdc.connectors.base.source.meta.split with annotations of type Experimental

Modifier and Type	Class	Description
class	SourceSplitBase	The split of table comes from a Table that splits by primary key.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.reader

Classes in org.apache.flink.cdc.connectors.base.source.reader with annotations of type Experimental

Modifier and Type	Class	Description
class	IncrementalSourceReader<T,C extends SourceConfig>	The multi-parallel source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.
class	IncrementalSourceReaderWithCommit	Record the LSN of checkpoint StreamSplit, which can be used to submit to the CDC source.
class	IncrementalSourceSplitReader<C extends SourceConfig>	Basic class read SourceSplitBase and return SourceRecord.

Uses of Experimental in org.apache.flink.cdc.connectors.base.source.reader.external

Classes in org.apache.flink.cdc.connectors.base.source.reader.external with annotations of type Experimental

Modifier and Type	Interface	Description
interface	Fetcher<T,Split>	Fetcher to fetch data of a table split, the split is either snapshot split SnapshotSplit or stream split StreamSplit.
interface	FetchTask<Split>	The task to fetching data of a Split.

Uses of Experimental in org.apache.flink.cdc.connectors.db2.source.dialect

Classes in org.apache.flink.cdc.connectors.db2.source.dialect with annotations of type Experimental

Modifier and Type	Class	Description
class	Db2Dialect	The JdbcDataSourceDialect implementation for Db2 datasource.

Uses of Experimental in org.apache.flink.cdc.connectors.iceberg.sink

Fields in org.apache.flink.cdc.connectors.iceberg.sink with annotations of type Experimental

Modifier and Type	Field	Description
static ConfigOption<String>	IcebergDataSinkOptions.JOB_ID_PREFIX
static ConfigOption<Integer>	IcebergDataSinkOptions.SINK_COMPACTION_COMMIT_INTERVAL
static ConfigOption<Boolean>	IcebergDataSinkOptions.SINK_COMPACTION_ENABLED
static ConfigOption<Integer>	IcebergDataSinkOptions.SINK_COMPACTION_PARALLELISM

Uses of Experimental in org.apache.flink.cdc.connectors.mongodb.source

Classes in org.apache.flink.cdc.connectors.mongodb.source with annotations of type Experimental

Modifier and Type	Class	Description
class	MongoDBSource<T>	The MongoDB CDC Source based on FLIP-27 which supports parallel reading snapshot of collection and then continue to capture data change from change stream.
class	MongoDBSourceBuilder<T>	The builder class for MongoDBSource to make it easier for the users to construct a MongoDBSource.

Uses of Experimental in org.apache.flink.cdc.connectors.mongodb.source.assigners.splitters

Classes in org.apache.flink.cdc.connectors.mongodb.source.assigners.splitters with annotations of type Experimental

Modifier and Type	Class	Description
class	MongoDBChunkSplitter	The splitter used to split collection into a set of chunks for MongoDB data source.

Uses of Experimental in org.apache.flink.cdc.connectors.mongodb.source.config

Fields in org.apache.flink.cdc.connectors.mongodb.source.config with annotations of type Experimental

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Boolean>	MongoDBSourceOptions.FULL_DOCUMENT_PRE_POST_IMAGE
static org.apache.flink.configuration.ConfigOption<Integer>	MongoDBSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SAMPLES
static org.apache.flink.configuration.ConfigOption<Integer>	MongoDBSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE_MB
static org.apache.flink.configuration.ConfigOption<Boolean>	MongoDBSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_ENABLED

Uses of Experimental in org.apache.flink.cdc.connectors.mongodb.source.dialect

Classes in org.apache.flink.cdc.connectors.mongodb.source.dialect with annotations of type Experimental

Modifier and Type	Class	Description
class	MongoDBDialect	The DataSourceDialect implementation for MongoDB datasource.

Uses of Experimental in org.apache.flink.cdc.connectors.mysql.source

Fields in org.apache.flink.cdc.connectors.mysql.source with annotations of type Experimental

Modifier and Type	Field	Description
static ConfigOption<Double>	MySqlDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	MySqlDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	MySqlDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<Boolean>	MySqlDataSourceOptions.INCLUDE_COMMENTS_ENABLED
static ConfigOption<String>	MySqlDataSourceOptions.METADATA_LIST
static ConfigOption<Boolean>	MySqlDataSourceOptions.PARSE_ONLINE_SCHEMA_CHANGES
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static ConfigOption<String>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	MySqlDataSourceOptions.TABLES_EXCLUDE
static ConfigOption<Boolean>	MySqlDataSourceOptions.TREAT_TINYINT1_AS_BOOLEAN_ENABLED
static ConfigOption<Boolean>	MySqlDataSourceOptions.USE_LEGACY_JSON_FORMAT

Uses of Experimental in org.apache.flink.cdc.connectors.mysql.source.config

Fields in org.apache.flink.cdc.connectors.mysql.source.config with annotations of type Experimental

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Double>	MySqlSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static org.apache.flink.configuration.ConfigOption<Double>	MySqlSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static org.apache.flink.configuration.ConfigOption<Integer>	MySqlSourceOptions.CHUNK_META_GROUP_SIZE
static org.apache.flink.configuration.ConfigOption<Boolean>	MySqlSourceOptions.PARSE_ONLINE_SCHEMA_CHANGES
static org.apache.flink.configuration.ConfigOption<Boolean>	MySqlSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP
static org.apache.flink.configuration.ConfigOption<String>	MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_CHUNK_KEY_COLUMN
static org.apache.flink.configuration.ConfigOption<Boolean>	MySqlSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_METADATA_RELEASE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	MySqlSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	MySqlSourceOptions.USE_LEGACY_JSON_FORMAT

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

Classes in org.apache.flink.cdc.connectors.oracle.source with annotations of type Experimental

Modifier and Type	Class	Description
class	OracleDialect	The JdbcDataSourceDialect implementation for Oracle datasource.

Fields in org.apache.flink.cdc.connectors.oracle.source with annotations of type Experimental

Modifier and Type	Field	Description
static ConfigOption<Double>	OracleDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	OracleDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	OracleDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<String>	OracleDataSourceOptions.DATABASE_CONNECTION_ADAPTER
static ConfigOption<String>	OracleDataSourceOptions.LOG_MINING_STRATEGY
static ConfigOption<String>	OracleDataSourceOptions.METADATA_LIST
static ConfigOption<Boolean>	OracleDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	OracleDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_BACKFILL_SKIP

Uses of Experimental in org.apache.flink.cdc.connectors.postgres.source

Classes in org.apache.flink.cdc.connectors.postgres.source with annotations of type Experimental

Modifier and Type	Class	Description
class	PostgresSourceBuilder<T>	The source builder for PostgresIncrementalSource.
static class	PostgresSourceBuilder.PostgresIncrementalSource<T>	The Postgres source based on the incremental snapshot framework.

Fields in org.apache.flink.cdc.connectors.postgres.source with annotations of type Experimental

Modifier and Type	Field	Description
static ConfigOption<Double>	PostgresDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	PostgresDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	PostgresDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<String>	PostgresDataSourceOptions.METADATA_LIST
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Boolean>	PostgresDataSourceOptions.SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	PostgresDataSourceOptions.TABLES_EXCLUDE

Uses of Experimental in org.apache.flink.cdc.connectors.postgres.source.reader

Classes in org.apache.flink.cdc.connectors.postgres.source.reader with annotations of type Experimental

Modifier and Type	Class	Description
class	PostgresSourceReader	The multi-parallel postgres source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.

Uses of Experimental in org.apache.flink.cdc.connectors.sqlserver.source

Fields in org.apache.flink.cdc.connectors.sqlserver.source with annotations of type Experimental

Modifier and Type	Field	Description
static ConfigOption<Double>	SqlServerDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_LOWER_BOUND
static ConfigOption<Double>	SqlServerDataSourceOptions.CHUNK_KEY_EVEN_DISTRIBUTION_FACTOR_UPPER_BOUND
static ConfigOption<Integer>	SqlServerDataSourceOptions.CHUNK_META_GROUP_SIZE
static ConfigOption<String>	SqlServerDataSourceOptions.METADATA_LIST
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_CLOSE_IDLE_READER_ENABLED
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_INCREMENTAL_SNAPSHOT_UNBOUNDED_CHUNK_FIRST_ENABLED
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCAN_NEWLY_ADDED_TABLE_ENABLED
static ConfigOption<Boolean>	SqlServerDataSourceOptions.SCHEMA_CHANGE_ENABLED
static ConfigOption<String>	SqlServerDataSourceOptions.TABLES_EXCLUDE

Uses of Experimental in org.apache.flink.cdc.connectors.sqlserver.source.dialect

Classes in org.apache.flink.cdc.connectors.sqlserver.source.dialect with annotations of type Experimental

Modifier and Type	Class	Description
class	SqlServerDialect	The JdbcDataSourceDialect implementation for SqlServer datasource.

Uses of Experimental in org.apache.flink.cdc.python

Classes in org.apache.flink.cdc.python with annotations of type Experimental

Modifier and Type	Class	Description
class	PythonUdf	Generic UDF that delegates to a Python function defined inline in YAML.

Uses of Experimental in org.apache.flink.cdc.runtime.operators.transform.converter

Classes in org.apache.flink.cdc.runtime.operators.transform.converter with annotations of type Experimental

Modifier and Type	Interface	Description
interface	PostTransformConverter	The PostTransformConverter applies to convert the DataChangeEvent after other part of TransformRule in PostTransformOperator.
class	PostTransformConverters	The PostTransformConverter utils.