Package org.apache.flink.cdc.connectors.db2.source.fetch
-
Class Summary Class Description Db2ScanFetchTask The task to work for fetching data of Db2 table snapshot split.Db2ScanFetchTask.Db2SnapshotSplitReadTask A wrapped task to fetch snapshot split of table.Db2SourceFetchTaskContext The context for fetch task that fetching data of snapshot split from Db2 data source.Db2SourceFetchTaskContext.Db2EventMetadataProvider Copied from debezium for accessing here.Db2StreamFetchTask The task to work for fetching data of Db2 table stream split .Db2StreamFetchTask.StreamSplitReadTask A wrapped task to read all redo logs for table and also supports read bounded (from lowWatermark to highWatermark) redo logs.