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

Packages that use org.apache.flink.cdc.connectors.base.source.reader

Package	Description
org.apache.flink.cdc.connectors.base.source
org.apache.flink.cdc.connectors.base.source.reader
org.apache.flink.cdc.connectors.mongodb.source.reader
org.apache.flink.cdc.connectors.oracle.source.reader
org.apache.flink.cdc.connectors.postgres.source.reader
org.apache.flink.cdc.connectors.sqlserver.source.reader

Classes in org.apache.flink.cdc.connectors.base.source.reader used by org.apache.flink.cdc.connectors.base.source

Class	Description
IncrementalSourceReader	The multi-parallel source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.

Classes in org.apache.flink.cdc.connectors.base.source.reader used by org.apache.flink.cdc.connectors.base.source.reader

Class	Description
IncrementalSourceReader	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.
IncrementalSourceRecordEmitter.OutputCollector	An adapter between SourceOutput and Collector.
IncrementalSourceSplitReader	Basic class read SourceSplitBase and return SourceRecord.

Classes in org.apache.flink.cdc.connectors.base.source.reader used by org.apache.flink.cdc.connectors.mongodb.source.reader

Class	Description
IncrementalSourceRecordEmitter	The RecordEmitter implementation for IncrementalSourceReader.

Classes in org.apache.flink.cdc.connectors.base.source.reader used by org.apache.flink.cdc.connectors.oracle.source.reader

Class	Description
IncrementalSourceReader	The multi-parallel source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.
IncrementalSourceRecordEmitter	The RecordEmitter implementation for IncrementalSourceReader.

Classes in org.apache.flink.cdc.connectors.base.source.reader used by org.apache.flink.cdc.connectors.postgres.source.reader

Class	Description
IncrementalSourceReader	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	The RecordEmitter implementation for IncrementalSourceReader.

Classes in org.apache.flink.cdc.connectors.base.source.reader used by org.apache.flink.cdc.connectors.sqlserver.source.reader

Class	Description
IncrementalSourceRecordEmitter	The RecordEmitter implementation for IncrementalSourceReader.