Uses of Interface
org.apache.flink.cdc.common.source.DataSource

Packages that use DataSource

Package	Description
org.apache.flink.cdc.common.factories
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.connectors.fluss.factory
org.apache.flink.cdc.connectors.fluss.source
org.apache.flink.cdc.connectors.mysql.factory
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.oracle.factory
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.postgres.factory
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.sqlserver.factory
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.values.factory
org.apache.flink.cdc.connectors.values.source

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

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

Modifier and Type	Method	Description
DataSource	DataSourceFactory.createDataSource(Factory.Context context)	Creates a DataSource instance.

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

Methods in org.apache.flink.cdc.composer.flink.translator that return DataSource

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

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

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	DataSourceTranslator.translate(SourceDef sourceDef, DataSource dataSource, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, int sourceParallelism, OperatorUidGenerator operatorUidGenerator)

Uses of DataSource in org.apache.flink.cdc.connectors.fluss.factory

Methods in org.apache.flink.cdc.connectors.fluss.factory that return DataSource

Modifier and Type	Method	Description
DataSource	FlussDataSourceFactory.createDataSource(Factory.Context context)

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

Classes in org.apache.flink.cdc.connectors.fluss.source that implement DataSource

Modifier and Type	Class	Description
class	FlussDataSource	A CDC-specific DataSource implementation for Fluss.

Uses of DataSource in org.apache.flink.cdc.connectors.mysql.factory

Methods in org.apache.flink.cdc.connectors.mysql.factory that return DataSource

Modifier and Type	Method	Description
DataSource	MySqlDataSourceFactory.createDataSource(Factory.Context context)

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

Classes in org.apache.flink.cdc.connectors.mysql.source that implement DataSource

Modifier and Type	Class	Description
class	MySqlDataSource	A DataSource for mysql cdc connector.

Uses of DataSource in org.apache.flink.cdc.connectors.oracle.factory

Methods in org.apache.flink.cdc.connectors.oracle.factory that return DataSource

Modifier and Type	Method	Description
DataSource	OracleDataSourceFactory.createDataSource(Factory.Context context)

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

Classes in org.apache.flink.cdc.connectors.oracle.source that implement DataSource

Modifier and Type	Class	Description
class	OracleDataSource	A DynamicTableSource that describes how to create a Oracle redo log from a logical description.

Uses of DataSource in org.apache.flink.cdc.connectors.postgres.factory

Methods in org.apache.flink.cdc.connectors.postgres.factory that return DataSource

Modifier and Type	Method	Description
DataSource	PostgresDataSourceFactory.createDataSource(Factory.Context context)

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

Classes in org.apache.flink.cdc.connectors.postgres.source that implement DataSource

Modifier and Type	Class	Description
class	PostgresDataSource	A DataSource for Postgres cdc connector.

Uses of DataSource in org.apache.flink.cdc.connectors.sqlserver.factory

Methods in org.apache.flink.cdc.connectors.sqlserver.factory that return DataSource

Modifier and Type	Method	Description
DataSource	SqlServerDataSourceFactory.createDataSource(Factory.Context context)

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

Classes in org.apache.flink.cdc.connectors.sqlserver.source that implement DataSource

Modifier and Type	Class	Description
class	SqlServerDataSource	A DataSource for SQL Server CDC connector.

Uses of DataSource in org.apache.flink.cdc.connectors.values.factory

Methods in org.apache.flink.cdc.connectors.values.factory that return DataSource

Modifier and Type	Method	Description
DataSource	ValuesDataFactory.createDataSource(Factory.Context context)

Uses of DataSource in org.apache.flink.cdc.connectors.values.source

Classes in org.apache.flink.cdc.connectors.values.source that implement DataSource

Modifier and Type	Class	Description
class	ValuesDataSource	A DataSource for "values" connector that supports schema evolution.