Module cdc 

Functions

bind_cdc_pk_comparisons_externally 🔒

bind_cdc_table_schema 🔒

Derive the schema of a CDC table from explicit SQL columns and constraints.

bind_cdc_table_schema_externally 🔒

Derive the schema of a CDC table from its upstream external table.

compile_debezium_column_filter_patterns 🔒

derive_with_options_for_cdc_table 🔒

Derive connector properties and normalize external_table_name for CDC tables.

not_null_check_for_cdc_table 🔒

parse_postgres_cdc_external_table_name 🔒

Parse the schema/table name from the CDC TABLE clause.

reject_pk_filtered_by_debezium_column_filter 🔒

Reject a CDC table when a primary-key column is filtered out of Debezium change-event values via debezium.column.exclude.list or debezium.column.include.list.

reject_pk_filtered_by_debezium_column_filter_inner 🔒

sanity_check_for_table_on_cdc_source 🔒