Uses of Class
io.debezium.connector.mysql.MySqlConnection

Packages that use MySqlConnection

Package	Description
io.debezium.connector.mysql
org.apache.flink.cdc.connectors.mysql.debezium
org.apache.flink.cdc.connectors.mysql.debezium.task
org.apache.flink.cdc.connectors.mysql.debezium.task.context
org.apache.flink.cdc.connectors.mysql.source.offset
org.apache.flink.cdc.connectors.mysql.source.utils
org.apache.flink.cdc.connectors.mysql.utils

Uses of MySqlConnection in io.debezium.connector.mysql

Constructors in io.debezium.connector.mysql with parameters of type MySqlConnection

Constructor and Description

MySqlStreamingChangeEventSource(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig, MySqlConnection connection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.mysql.MySqlPartition,io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.mysql.MySqlTaskContext taskContext, io.debezium.connector.mysql.MySqlStreamingChangeEventSourceMetrics metrics)

Uses of MySqlConnection in org.apache.flink.cdc.connectors.mysql.debezium

Methods in org.apache.flink.cdc.connectors.mysql.debezium that return MySqlConnection

Modifier and Type	Method and Description
static MySqlConnection	DebeziumUtils.createMySqlConnection(io.debezium.config.Configuration dbzConfiguration, Properties jdbcProperties) Creates a new MySqlConnection, but not open the connection.
static MySqlConnection	DebeziumUtils.createMySqlConnection(MySqlSourceConfig sourceConfig) Creates a new MySqlConnection, but not open the connection.

Methods in org.apache.flink.cdc.connectors.mysql.debezium with parameters of type MySqlConnection

Modifier and Type	Method and Description
static BinlogOffset	DebeziumUtils.findBinlogOffset(long targetMs, MySqlConnection connection, MySqlSourceConfig mySqlSourceConfig)

Uses of MySqlConnection in org.apache.flink.cdc.connectors.mysql.debezium.task

Constructors in org.apache.flink.cdc.connectors.mysql.debezium.task with parameters of type MySqlConnection

Constructor and Description
MySqlBinlogSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig, MySqlConnection connection, EventDispatcherImpl<io.debezium.relational.TableId> dispatcher, SignalEventDispatcher signalEventDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.mysql.MySqlTaskContext taskContext, io.debezium.connector.mysql.MySqlStreamingChangeEventSourceMetrics metrics, MySqlBinlogSplit binlogSplit, java.util.function.Predicate<com.github.shyiko.mysql.binlog.event.Event> eventFilter)
MySqlSnapshotSplitReadTask(MySqlSourceConfig sourceConfig, io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig, io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics<io.debezium.connector.mysql.MySqlPartition> snapshotChangeEventSourceMetrics, io.debezium.connector.mysql.MySqlDatabaseSchema databaseSchema, MySqlConnection jdbcConnection, EventDispatcherImpl<io.debezium.relational.TableId> dispatcher, io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector, io.debezium.pipeline.EventDispatcher.SnapshotReceiver<io.debezium.connector.mysql.MySqlPartition> snapshotReceiver, io.debezium.util.Clock clock, MySqlSnapshotSplit snapshotSplit, SnapshotPhaseHooks hooks, boolean isBackfillSkipped)

Uses of MySqlConnection in org.apache.flink.cdc.connectors.mysql.debezium.task.context

Methods in org.apache.flink.cdc.connectors.mysql.debezium.task.context that return MySqlConnection

Modifier and Type	Method and Description
MySqlConnection	StatefulTaskContext.getConnection()

Constructors in org.apache.flink.cdc.connectors.mysql.debezium.task.context with parameters of type MySqlConnection

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

Uses of MySqlConnection in org.apache.flink.cdc.connectors.mysql.source.offset

Methods in org.apache.flink.cdc.connectors.mysql.source.offset with parameters of type MySqlConnection

Modifier and Type	Method and Description
static BinlogOffset	BinlogOffsetUtils.initializeEffectiveOffset(BinlogOffset offset, MySqlConnection connection, MySqlSourceConfig mySqlSourceConfig) Initialize the binlog offset according to the kind of binlog offset, so that the debezium reader could interpret it and seek the reader to the offset.

Uses of MySqlConnection in org.apache.flink.cdc.connectors.mysql.source.utils

Methods in org.apache.flink.cdc.connectors.mysql.source.utils with parameters of type MySqlConnection

Modifier and Type	Method and Description
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	TableDiscoveryUtils.discoverSchemaForCapturedTables(io.debezium.connector.mysql.MySqlPartition partition, List<io.debezium.relational.TableId> capturedTableIds, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	TableDiscoveryUtils.discoverSchemaForCapturedTables(io.debezium.connector.mysql.MySqlPartition partition, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	TableDiscoveryUtils.discoverSchemaForNewAddedTables(io.debezium.connector.mysql.MySqlPartition partition, List<io.debezium.relational.TableId> existedTables, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)

Uses of MySqlConnection in org.apache.flink.cdc.connectors.mysql.utils

Methods in org.apache.flink.cdc.connectors.mysql.utils with parameters of type MySqlConnection

Modifier and Type	Method and Description
static Schema	MySqlSchemaUtils.getTableSchema(io.debezium.connector.mysql.MySqlPartition partition, TableId tableId, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)