Uses of Class
io.debezium.connector.db2.Db2Connection

Packages that use Db2Connection

Package	Description
io.debezium.connector.db2
org.apache.flink.cdc.connectors.db2.source.fetch
org.apache.flink.cdc.connectors.db2.source.utils

Uses of Db2Connection in io.debezium.connector.db2

Constructors in io.debezium.connector.db2 with parameters of type Db2Connection

Constructor

Description

Db2StreamingChangeEventSource(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig, Db2Connection dataConnection, Db2Connection metadataConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.db2.Db2Partition,io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.db2.Db2DatabaseSchema schema)

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

Methods in org.apache.flink.cdc.connectors.db2.source.fetch that return Db2Connection

Modifier and Type	Method	Description
Db2Connection	Db2SourceFetchTaskContext.getConnection()
Db2Connection	Db2SourceFetchTaskContext.getMetaDataConnection()

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

Constructor	Description
Db2SnapshotSplitReadTask(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig, io.debezium.connector.db2.Db2OffsetContext previousOffset, io.debezium.pipeline.source.spi.SnapshotProgressListener<io.debezium.connector.db2.Db2Partition> snapshotProgressListener, io.debezium.connector.db2.Db2DatabaseSchema databaseSchema, Db2Connection jdbcConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.db2.Db2Partition,io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.EventDispatcher.SnapshotReceiver<io.debezium.connector.db2.Db2Partition> snapshotReceiver, SnapshotSplit snapshotSplit)
Db2SourceFetchTaskContext(JdbcSourceConfig sourceConfig, Db2Dialect dataSourceDialect, Db2Connection connection, Db2Connection metaDataConnection)
StreamSplitReadTask(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig, Db2Connection connection, Db2Connection metadataConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.db2.Db2Partition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.connector.db2.Db2DatabaseSchema schema, StreamSplit lsnSplit)

Uses of Db2Connection in org.apache.flink.cdc.connectors.db2.source.utils

Methods in org.apache.flink.cdc.connectors.db2.source.utils that return Db2Connection

Modifier and Type	Method	Description
static Db2Connection	Db2ConnectionUtils.createDb2Connection(io.debezium.relational.RelationalDatabaseConnectorConfig connectorConfig)

Methods in org.apache.flink.cdc.connectors.db2.source.utils with parameters of type Db2Connection

Modifier and Type	Method	Description
static io.debezium.connector.db2.Db2DatabaseSchema	Db2Utils.createDb2DatabaseSchema(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig, Db2Connection connection)
static LsnOffset	Db2Utils.currentLsn(Db2Connection connection)	Fetch current largest log sequence number (LSN) of the database.