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

Class Summary

Class	Description
PostgresPipelineRecordEmitter<T>	The RecordEmitter implementation for PostgreSQL pipeline connector.
PostgresSourceReader	The multi-parallel postgres source reader for table snapshot phase from SnapshotSplit and then single-parallel source reader for table stream phase from StreamSplit.
PostgresSourceRecordEmitter<T>	Record emitter that recognizes PostgresSchemaRecord as schema change events.