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

Class Summary

Class	Description
CDCPostgresDispatcher	Postgres Dispatcher for cdc source with watermark.
PostgresScanFetchTask	A FetchTask implementation for Postgres to read snapshot split.
PostgresScanFetchTask.PostgresSnapshotSplitReadTask	A SnapshotChangeEventSource implementation for Postgres to read snapshot split.
PostgresSourceFetchTaskContext	The context of PostgresScanFetchTask and PostgresStreamFetchTask.
PostgresStreamFetchTask	A FetchTask implementation for Postgres to read streaming changes.
PostgresStreamFetchTask.StreamSplitReadTask	A ChangeEventSource implementation for Postgres to read streaming changes.
StoppableChangeEventSourceContext	A change event source context that can stop the running source by invoking StoppableChangeEventSourceContext.stopChangeEventSource().