Package org.apache.flink.cdc.connectors.postgres.table
-
Class Summary Class Description PostgreSQLDeserializationConverterFactory Used to createDeserializationRuntimeConverterFactoryspecified to PostgreSQL.PostgreSQLTableFactory Factory for creating configured instance ofPostgreSQLTableSource.PostgreSQLTableSource ADynamicTableSourcethat describes how to create a PostgreSQL source from a logical description.PostgresValueValidator TheRowDataDebeziumDeserializeSchema.ValueValidatorfor Postgres connector. -
Enum Summary Enum Description PostgreSQLReadableMetadata Defines the supported metadata columns forPostgreSQLTableSource.