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

Class Summary

Class	Description
IncrementalSourceReader<T,C extends SourceConfig>	The multi-parallel source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.
IncrementalSourceReaderContext	A wrapper class that wraps SourceReaderContext for sharing message between IncrementalSourceReader and IncrementalSourceSplitReader.
IncrementalSourceReaderWithCommit	Record the LSN of checkpoint StreamSplit, which can be used to submit to the CDC source.
IncrementalSourceRecordEmitter<T>	The RecordEmitter implementation for IncrementalSourceReader.
IncrementalSourceRecordEmitter.OutputCollector<T>	An adapter between SourceOutput and Collector.
IncrementalSourceSplitReader<C extends SourceConfig>	Basic class read SourceSplitBase and return SourceRecord.