Package org.apache.flink.cdc.connectors.base.source

Class Summary

Class	Description
EmbeddedFlinkDatabaseHistory	A DatabaseHistory implementation which store the latest table schema in Flink state.
IncrementalSource<T,C extends SourceConfig>	The basic source of Incremental Snapshot framework for datasource, it is based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change by streaming reading.