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

Class Summary

Class	Description
DatabaseNameMetadataColumn	A SupportedMetadataColumn for database_name.
OpTsMetadataColumn	A SupportedMetadataColumn for op_ts.
PostgresChunkSplitter	The splitter to split the table into chunks using primary-key (by default) or a given split key.
PostgresConnectionPoolFactory	A connection pool factory to create pooled Postgres HikariDataSource.
PostgresDataSource	A DataSource for Postgres cdc connector.
PostgresDataSource.PostgresPipelineSource<T>	The JdbcIncrementalSource implementation for Postgres.
PostgresDataSourceOptions	Configurations for PostgresDataSource.
PostgresDialect	The dialect for Postgres.
PostgresEventDeserializer	Event deserializer for PostgresDataSource.
PostgresMetadataAccessor	MetadataAccessor for PostgresDataSource.
PostgresSchemaDataTypeInference	DataType inference for PostgresSQL debezium Schema.
PostgresSourceBuilder<T>	The source builder for PostgresIncrementalSource.
PostgresSourceBuilder.PostgresIncrementalSource<T>	The Postgres source based on the incremental snapshot framework.
SchemaNameMetadataColumn	A SupportedMetadataColumn for schema_name.
TableNameMetadataColumn	A SupportedMetadataColumn for table_name.