Uses of Class
org.apache.flink.cdc.connectors.base.config.JdbcSourceConfig

Packages that use JdbcSourceConfig

Package	Description
org.apache.flink.cdc.connectors.base.config
org.apache.flink.cdc.connectors.base.dialect
org.apache.flink.cdc.connectors.base.relational.connection
org.apache.flink.cdc.connectors.base.source.assigner.splitter
org.apache.flink.cdc.connectors.base.source.reader.external
org.apache.flink.cdc.connectors.db2.source.config
org.apache.flink.cdc.connectors.db2.source.dialect
org.apache.flink.cdc.connectors.db2.source.fetch
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.source.assigner.splitter
org.apache.flink.cdc.connectors.oracle.source.config
org.apache.flink.cdc.connectors.oracle.source.reader
org.apache.flink.cdc.connectors.oracle.source.reader.fetch
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.config
org.apache.flink.cdc.connectors.postgres.source.fetch
org.apache.flink.cdc.connectors.sqlserver.source.config
org.apache.flink.cdc.connectors.sqlserver.source.dialect
org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch

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

Methods in org.apache.flink.cdc.connectors.base.config that return JdbcSourceConfig

Modifier and Type	Method	Description
abstract JdbcSourceConfig	JdbcSourceConfigFactory.create(int subtask)

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

Methods in org.apache.flink.cdc.connectors.base.dialect with parameters of type JdbcSourceConfig

Modifier and Type	Method	Description
List<io.debezium.relational.TableId>	JdbcDataSourceDialect.discoverDataCollections(JdbcSourceConfig sourceConfig)	Discovers the list of table to capture.
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	JdbcDataSourceDialect.discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)	Discovers the captured tables' schema by SourceConfig.
io.debezium.jdbc.JdbcConnection	JdbcDataSourceDialect.openJdbcConnection(JdbcSourceConfig sourceConfig)	Creates and opens a new JdbcConnection backing connection pool.

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

Methods in org.apache.flink.cdc.connectors.base.relational.connection with parameters of type JdbcSourceConfig

Modifier and Type	Method	Description
com.zaxxer.hikari.HikariDataSource	JdbcConnectionPoolFactory.createPooledDataSource(JdbcSourceConfig sourceConfig)
abstract String	JdbcConnectionPoolFactory.getJdbcUrl(JdbcSourceConfig sourceConfig)	due to relational database url of the forms are different, e.g.
String	JdbcConnectionPools.getJdbcUrl(JdbcSourceConfig sourceConfig, String dataSourcePoolFactoryIdentifier)	this method is only supported for test.
com.zaxxer.hikari.HikariDataSource	JdbcConnectionPools.getOrCreateConnectionPool(ConnectionPoolId poolId, JdbcSourceConfig sourceConfig)

Constructors in org.apache.flink.cdc.connectors.base.relational.connection with parameters of type JdbcSourceConfig

Constructor	Description
JdbcConnectionFactory(JdbcSourceConfig sourceConfig, JdbcConnectionPoolFactory jdbcConnectionPoolFactory)

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

Fields in org.apache.flink.cdc.connectors.base.source.assigner.splitter declared as JdbcSourceConfig

Modifier and Type	Field	Description
protected JdbcSourceConfig	JdbcSourceChunkSplitter.sourceConfig

Constructors in org.apache.flink.cdc.connectors.base.source.assigner.splitter with parameters of type JdbcSourceConfig

Constructor	Description
JdbcSourceChunkSplitter(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dialect, io.debezium.relational.TableId currentSplittingTableId, ChunkSplitterState.ChunkBound nextChunkStart, Integer nextChunkId)
JdbcSourceChunkSplitter(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dialect, ChunkSplitterState chunkSplitterState)

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

Fields in org.apache.flink.cdc.connectors.base.source.reader.external declared as JdbcSourceConfig

Modifier and Type	Field	Description
protected JdbcSourceConfig	JdbcSourceFetchTaskContext.sourceConfig

Constructors in org.apache.flink.cdc.connectors.base.source.reader.external with parameters of type JdbcSourceConfig

Constructor	Description
JdbcSourceFetchTaskContext(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dataSourceDialect)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.db2.source.config

Subclasses of JdbcSourceConfig in org.apache.flink.cdc.connectors.db2.source.config

Modifier and Type	Class	Description
class	Db2SourceConfig	Describes the connection information of the Db2 database and the configuration information for performing snapshotting and streaming reading, such as splitSize.

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

Methods in org.apache.flink.cdc.connectors.db2.source.dialect with parameters of type JdbcSourceConfig

Modifier and Type	Method	Description
ChunkSplitter	Db2Dialect.createChunkSplitter(JdbcSourceConfig sourceConfig)
ChunkSplitter	Db2Dialect.createChunkSplitter(JdbcSourceConfig sourceConfig, ChunkSplitterState chunkSplitterState)
FetchTask.Context	Db2Dialect.createFetchTaskContext(JdbcSourceConfig sourceConfig)	The task context used for fetch task to fetch data from external systems.
List<io.debezium.relational.TableId>	Db2Dialect.discoverDataCollections(JdbcSourceConfig sourceConfig)
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	Db2Dialect.discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)
Offset	Db2Dialect.displayCurrentOffset(JdbcSourceConfig sourceConfig)
String	Db2PooledDataSourceFactory.getJdbcUrl(JdbcSourceConfig sourceConfig)
boolean	Db2Dialect.isDataCollectionIdCaseSensitive(JdbcSourceConfig sourceConfig)
boolean	Db2Dialect.isIncludeDataCollection(JdbcSourceConfig sourceConfig, io.debezium.relational.TableId tableId)	Check if the tableId is included in SourceConfig.
io.debezium.jdbc.JdbcConnection	Db2Dialect.openJdbcConnection(JdbcSourceConfig sourceConfig)

Constructors in org.apache.flink.cdc.connectors.db2.source.dialect with parameters of type JdbcSourceConfig

Constructor	Description
Db2ChunkSplitter(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dialect, ChunkSplitterState chunkSplitterState)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.db2.source.fetch

Constructors in org.apache.flink.cdc.connectors.db2.source.fetch with parameters of type JdbcSourceConfig

Constructor	Description
Db2SourceFetchTaskContext(JdbcSourceConfig sourceConfig, Db2Dialect dataSourceDialect, Db2Connection connection, Db2Connection metaDataConnection)

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

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

Modifier and Type	Method	Description
ChunkSplitter	OracleDialect.createChunkSplitter(JdbcSourceConfig sourceConfig)
ChunkSplitter	OracleDialect.createChunkSplitter(JdbcSourceConfig sourceConfig, ChunkSplitterState chunkSplitterState)
OracleSourceFetchTaskContext	OracleDialect.createFetchTaskContext(JdbcSourceConfig taskSourceConfig)
List<io.debezium.relational.TableId>	OracleDialect.discoverDataCollections(JdbcSourceConfig sourceConfig)
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	OracleDialect.discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)
Offset	OracleDialect.displayCurrentOffset(JdbcSourceConfig sourceConfig)
String	OraclePooledDataSourceFactory.getJdbcUrl(JdbcSourceConfig sourceConfig)
boolean	OracleDialect.isDataCollectionIdCaseSensitive(JdbcSourceConfig sourceConfig)
boolean	OracleDialect.isIncludeDataCollection(JdbcSourceConfig sourceConfig, io.debezium.relational.TableId tableId)
io.debezium.jdbc.JdbcConnection	OracleDialect.openJdbcConnection(JdbcSourceConfig sourceConfig)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.oracle.source.assigner.splitter

Constructors in org.apache.flink.cdc.connectors.oracle.source.assigner.splitter with parameters of type JdbcSourceConfig

Constructor	Description
OracleChunkSplitter(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dialect, ChunkSplitterState chunkSplitterState)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.oracle.source.config

Subclasses of JdbcSourceConfig in org.apache.flink.cdc.connectors.oracle.source.config

Modifier and Type	Class	Description
class	OracleSourceConfig	Describes the connection information of the Oracle database and the configuration information for performing snapshotting and streaming reading, such as splitSize.

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.oracle.source.reader

Methods in org.apache.flink.cdc.connectors.oracle.source.reader that return types with arguments of type JdbcSourceConfig

Modifier and Type	Method	Description
IncrementalSourceReader<Event,JdbcSourceConfig>	OracleTableSourceReader.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.oracle.source.reader.fetch

Constructors in org.apache.flink.cdc.connectors.oracle.source.reader.fetch with parameters of type JdbcSourceConfig

Constructor	Description
OracleSourceFetchTaskContext(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dataSourceDialect)

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

Methods in org.apache.flink.cdc.connectors.postgres.source with parameters of type JdbcSourceConfig

Modifier and Type	Method	Description
ChunkSplitter	PostgresDialect.createChunkSplitter(JdbcSourceConfig sourceConfig)
ChunkSplitter	PostgresDialect.createChunkSplitter(JdbcSourceConfig sourceConfig, ChunkSplitterState chunkSplitterState)
JdbcSourceFetchTaskContext	PostgresDialect.createFetchTaskContext(JdbcSourceConfig taskSourceConfig)
List<io.debezium.relational.TableId>	PostgresDialect.discoverDataCollections(JdbcSourceConfig sourceConfig)
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	PostgresDialect.discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)
Offset	PostgresDialect.displayCommittedOffset(JdbcSourceConfig sourceConfig)
Offset	PostgresDialect.displayCurrentOffset(JdbcSourceConfig sourceConfig)
String	PostgresConnectionPoolFactory.getJdbcUrl(JdbcSourceConfig sourceConfig)
boolean	PostgresDialect.isDataCollectionIdCaseSensitive(JdbcSourceConfig sourceConfig)
boolean	PostgresDialect.isIncludeDataCollection(JdbcSourceConfig sourceConfig, io.debezium.relational.TableId tableId)
io.debezium.jdbc.JdbcConnection	PostgresDialect.openJdbcConnection(JdbcSourceConfig sourceConfig)

Constructors in org.apache.flink.cdc.connectors.postgres.source with parameters of type JdbcSourceConfig

Constructor	Description
PostgresChunkSplitter(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dialect, ChunkSplitterState chunkSplitterState)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.postgres.source.config

Subclasses of JdbcSourceConfig in org.apache.flink.cdc.connectors.postgres.source.config

Modifier and Type	Class	Description
class	PostgresSourceConfig	The configuration for Postgres CDC source.

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.postgres.source.fetch

Constructors in org.apache.flink.cdc.connectors.postgres.source.fetch with parameters of type JdbcSourceConfig

Constructor	Description
PostgresSourceFetchTaskContext(JdbcSourceConfig sourceConfig, PostgresDialect dataSourceDialect)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.sqlserver.source.config

Subclasses of JdbcSourceConfig in org.apache.flink.cdc.connectors.sqlserver.source.config

Modifier and Type	Class	Description
class	SqlServerSourceConfig	Describes the connection information of the SQL Server database and the configuration information for performing snapshotting and streaming reading, such as splitSize.

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

Methods in org.apache.flink.cdc.connectors.sqlserver.source.dialect with parameters of type JdbcSourceConfig

Modifier and Type	Method	Description
ChunkSplitter	SqlServerDialect.createChunkSplitter(JdbcSourceConfig sourceConfig)
ChunkSplitter	SqlServerDialect.createChunkSplitter(JdbcSourceConfig sourceConfig, ChunkSplitterState chunkSplitterState)
SqlServerSourceFetchTaskContext	SqlServerDialect.createFetchTaskContext(JdbcSourceConfig taskSourceConfig)
List<io.debezium.relational.TableId>	SqlServerDialect.discoverDataCollections(JdbcSourceConfig sourceConfig)
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	SqlServerDialect.discoverDataCollectionSchemas(JdbcSourceConfig sourceConfig)
Offset	SqlServerDialect.displayCurrentOffset(JdbcSourceConfig sourceConfig)
String	SqlServerPooledDataSourceFactory.getJdbcUrl(JdbcSourceConfig sourceConfig)
boolean	SqlServerDialect.isDataCollectionIdCaseSensitive(JdbcSourceConfig sourceConfig)
boolean	SqlServerDialect.isIncludeDataCollection(JdbcSourceConfig sourceConfig, io.debezium.relational.TableId tableId)
io.debezium.jdbc.JdbcConnection	SqlServerDialect.openJdbcConnection(JdbcSourceConfig sourceConfig)

Constructors in org.apache.flink.cdc.connectors.sqlserver.source.dialect with parameters of type JdbcSourceConfig

Constructor	Description
SqlServerChunkSplitter(JdbcSourceConfig sourceConfig, JdbcDataSourceDialect dialect, ChunkSplitterState chunkSplitterState)

Uses of JdbcSourceConfig in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch

Constructors in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch with parameters of type JdbcSourceConfig

Constructor	Description
SqlServerSourceFetchTaskContext(JdbcSourceConfig sourceConfig, SqlServerDialect dataSourceDialect, io.debezium.connector.sqlserver.SqlServerConnection connection, io.debezium.connector.sqlserver.SqlServerConnection metaDataConnection)