Uses of Class
com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig

Packages that use MySqlSourceConfig

Package	Description
com.ververica.cdc.connectors.mysql
com.ververica.cdc.connectors.mysql.debezium
com.ververica.cdc.connectors.mysql.debezium.task.context
com.ververica.cdc.connectors.mysql.schema
com.ververica.cdc.connectors.mysql.source.assigners
com.ververica.cdc.connectors.mysql.source.config
com.ververica.cdc.connectors.mysql.source.connection
com.ververica.cdc.connectors.mysql.source.enumerator
com.ververica.cdc.connectors.mysql.source.reader
com.ververica.cdc.connectors.mysql.source.utils

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql

Constructors in com.ververica.cdc.connectors.mysql with parameters of type MySqlSourceConfig

Constructor and Description
MySqlValidator(MySqlSourceConfig sourceConfig)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.debezium

Methods in com.ververica.cdc.connectors.mysql.debezium with parameters of type MySqlSourceConfig

Modifier and Type	Method and Description
static List<io.debezium.relational.TableId>	DebeziumUtils.discoverCapturedTables(io.debezium.jdbc.JdbcConnection jdbc, MySqlSourceConfig sourceConfig)
static io.debezium.jdbc.JdbcConnection	DebeziumUtils.openJdbcConnection(MySqlSourceConfig sourceConfig) Creates and opens a new JdbcConnection backing connection pool.

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.debezium.task.context

Methods in com.ververica.cdc.connectors.mysql.debezium.task.context that return MySqlSourceConfig

Modifier and Type	Method and Description
MySqlSourceConfig	StatefulTaskContext.getSourceConfig()

Constructors in com.ververica.cdc.connectors.mysql.debezium.task.context with parameters of type MySqlSourceConfig

Constructor and Description
StatefulTaskContext(MySqlSourceConfig sourceConfig, com.github.shyiko.mysql.binlog.BinaryLogClient binaryLogClient, io.debezium.connector.mysql.MySqlConnection connection)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.schema

Constructors in com.ververica.cdc.connectors.mysql.schema with parameters of type MySqlSourceConfig

Constructor and Description
MySqlSchema(MySqlSourceConfig sourceConfig, boolean isTableIdCaseSensitive)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.source.assigners

Constructors in com.ververica.cdc.connectors.mysql.source.assigners with parameters of type MySqlSourceConfig

Constructor and Description
MySqlBinlogSplitAssigner(MySqlSourceConfig sourceConfig)
MySqlBinlogSplitAssigner(MySqlSourceConfig sourceConfig, BinlogPendingSplitsState checkpoint)
MySqlHybridSplitAssigner(MySqlSourceConfig sourceConfig, int currentParallelism, HybridPendingSplitsState checkpoint)
MySqlHybridSplitAssigner(MySqlSourceConfig sourceConfig, int currentParallelism, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive)
MySqlSnapshotSplitAssigner(MySqlSourceConfig sourceConfig, int currentParallelism, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive)
MySqlSnapshotSplitAssigner(MySqlSourceConfig sourceConfig, int currentParallelism, SnapshotPendingSplitsState checkpoint)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.source.config

Methods in com.ververica.cdc.connectors.mysql.source.config that return MySqlSourceConfig

Modifier and Type	Method and Description
MySqlSourceConfig	MySqlSourceConfigFactory.createConfig(int subtaskId) Creates a new MySqlSourceConfig for the given subtask subtaskId.

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.source.connection

Methods in com.ververica.cdc.connectors.mysql.source.connection with parameters of type MySqlSourceConfig

Modifier and Type	Method and Description
static com.zaxxer.hikari.HikariDataSource	PooledDataSourceFactory.createPooledDataSource(MySqlSourceConfig sourceConfig)
com.zaxxer.hikari.HikariDataSource	JdbcConnectionPools.getOrCreateConnectionPool(ConnectionPoolId poolId, MySqlSourceConfig sourceConfig)
com.zaxxer.hikari.HikariDataSource	ConnectionPools.getOrCreateConnectionPool(ConnectionPoolId poolId, MySqlSourceConfig sourceConfig) Gets a connection pool from pools, create a new pool if the pool does not exists in the connection pools .

Constructors in com.ververica.cdc.connectors.mysql.source.connection with parameters of type MySqlSourceConfig

Constructor and Description
JdbcConnectionFactory(MySqlSourceConfig sourceConfig)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.source.enumerator

Constructors in com.ververica.cdc.connectors.mysql.source.enumerator with parameters of type MySqlSourceConfig

Constructor and Description
MySqlSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> context, MySqlSourceConfig sourceConfig, MySqlSplitAssigner splitAssigner)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.source.reader

Constructors in com.ververica.cdc.connectors.mysql.source.reader with parameters of type MySqlSourceConfig

Constructor and Description
MySqlSourceReader(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>> elementQueue, java.util.function.Supplier<MySqlSplitReader> splitReaderSupplier, org.apache.flink.connector.base.source.reader.RecordEmitter<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplitState> recordEmitter, org.apache.flink.configuration.Configuration config, MySqlSourceReaderContext context, MySqlSourceConfig sourceConfig)
MySqlSplitReader(MySqlSourceConfig sourceConfig, int subtaskId, MySqlSourceReaderContext context)

Uses of MySqlSourceConfig in com.ververica.cdc.connectors.mysql.source.utils

Methods in com.ververica.cdc.connectors.mysql.source.utils with parameters of type MySqlSourceConfig

Modifier and Type	Method and Description
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	TableDiscoveryUtils.discoverCapturedTableSchemas(MySqlSourceConfig sourceConfig, io.debezium.connector.mysql.MySqlConnection jdbc)