Package org.apache.flink.cdc.connectors.db2.source.fetch

Class Db2SourceFetchTaskContext

java.lang.Object

org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext

org.apache.flink.cdc.connectors.db2.source.fetch.Db2SourceFetchTaskContext

All Implemented Interfaces:

FetchTask.Context

public class Db2SourceFetchTaskContext
extends JdbcSourceFetchTaskContext

The context for fetch task that fetching data of snapshot split from Db2 data source.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Db2SourceFetchTaskContext.Db2EventMetadataProvider	Copied from debezium for accessing here.

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext

dataSourceDialect, dbzConnectorConfig, schemaNameAdjuster, sourceConfig

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(SourceSplitBase sourceSplitBase)
Db2Connection	getConnection()
io.debezium.connector.db2.Db2DatabaseSchema	getDatabaseSchema()
io.debezium.connector.db2.Db2ConnectorConfig	getDbzConnectorConfig()
io.debezium.pipeline.ErrorHandler	getErrorHandler()
JdbcSourceEventDispatcher	getEventDispatcher()
Db2Connection	getMetaDataConnection()
io.debezium.connector.db2.Db2OffsetContext	getOffsetContext()
io.debezium.connector.db2.Db2Partition	getPartition()
io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent>	getQueue()
io.debezium.util.SchemaNameAdjuster	getSchemaNameAdjuster()
io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics<io.debezium.connector.db2.Db2Partition>	getSnapshotChangeEventSourceMetrics()
io.debezium.pipeline.EventDispatcher.SnapshotReceiver<io.debezium.connector.db2.Db2Partition>	getSnapshotReceiver()
Db2SourceConfig	getSourceConfig()
org.apache.flink.table.types.logical.RowType	getSplitType(io.debezium.relational.Table table)
io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics<io.debezium.connector.db2.Db2Partition>	getStreamingChangeEventSourceMetrics()
Offset	getStreamOffset(org.apache.kafka.connect.source.SourceRecord record)
io.debezium.relational.Tables.TableFilter	getTableFilter()
WatermarkDispatcher	getWaterMarkDispatcher()

Methods inherited from class org.apache.flink.cdc.connectors.base.source.reader.external.JdbcSourceFetchTaskContext

formatMessageTimestamp, getDataSourceDialect, getSplitKey, getTableId, isDataChangeRecord, isRecordBetween, rewriteOutputBuffer, setDbzConnectorConfig, supportsSplitKeyOptimization

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Db2SourceFetchTaskContext

public Db2SourceFetchTaskContext(JdbcSourceConfig sourceConfig,
                                 Db2Dialect dataSourceDialect,
                                 Db2Connection connection,
                                 Db2Connection metaDataConnection)

Method Detail

configure

public void configure(SourceSplitBase sourceSplitBase)

getQueue

public io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> getQueue()

getTableFilter

public io.debezium.relational.Tables.TableFilter getTableFilter()

getStreamOffset

public Offset getStreamOffset(org.apache.kafka.connect.source.SourceRecord record)

getDatabaseSchema

public io.debezium.connector.db2.Db2DatabaseSchema getDatabaseSchema()

Specified by:

getDatabaseSchema in class JdbcSourceFetchTaskContext

getSplitType

public org.apache.flink.table.types.logical.RowType getSplitType(io.debezium.relational.Table table)

Specified by:

getSplitType in class JdbcSourceFetchTaskContext

getErrorHandler

public io.debezium.pipeline.ErrorHandler getErrorHandler()

Specified by:

getErrorHandler in class JdbcSourceFetchTaskContext

getDbzConnectorConfig

public io.debezium.connector.db2.Db2ConnectorConfig getDbzConnectorConfig()

Overrides:

getDbzConnectorConfig in class JdbcSourceFetchTaskContext

getSourceConfig

public Db2SourceConfig getSourceConfig()

Specified by:

getSourceConfig in interface FetchTask.Context

Overrides:

getSourceConfig in class JdbcSourceFetchTaskContext

getEventDispatcher

public JdbcSourceEventDispatcher getEventDispatcher()

Specified by:

getEventDispatcher in class JdbcSourceFetchTaskContext

getWaterMarkDispatcher

public WatermarkDispatcher getWaterMarkDispatcher()

Specified by:

getWaterMarkDispatcher in class JdbcSourceFetchTaskContext

getSnapshotReceiver

public io.debezium.pipeline.EventDispatcher.SnapshotReceiver<io.debezium.connector.db2.Db2Partition> getSnapshotReceiver()

getOffsetContext

public io.debezium.connector.db2.Db2OffsetContext getOffsetContext()

Specified by:

getOffsetContext in class JdbcSourceFetchTaskContext

getPartition

public io.debezium.connector.db2.Db2Partition getPartition()

Specified by:

getPartition in class JdbcSourceFetchTaskContext

getConnection

public Db2Connection getConnection()

getMetaDataConnection

public Db2Connection getMetaDataConnection()

getSnapshotChangeEventSourceMetrics

public io.debezium.pipeline.metrics.SnapshotChangeEventSourceMetrics<io.debezium.connector.db2.Db2Partition> getSnapshotChangeEventSourceMetrics()

getStreamingChangeEventSourceMetrics

public io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics<io.debezium.connector.db2.Db2Partition> getStreamingChangeEventSourceMetrics()

close

public void close()
           throws Exception

Throws:

Exception

getSchemaNameAdjuster

public io.debezium.util.SchemaNameAdjuster getSchemaNameAdjuster()

Overrides:

getSchemaNameAdjuster in class JdbcSourceFetchTaskContext