Module alter_source_with_sr

Functions

alter_definition_format_encode

Apply the new format_encode_options to the source/table definition.

check_format_encode

Check if the original source is created with FORMAT .. ENCODE .. clause, and if the FORMAT and ENCODE are modified.

columns_minus 🔒

Returns the columns in columns_a but not in columns_b.

encode_type_to_encode 🔒

fetch_source_catalog_with_db_schema_id

Fetch the source catalog.

format_type_to_format 🔒

get_format_encode_from_source 🔒

handle_alter_source_with_sr

handler_refresh_schema

refresh_sr_and_get_columns_diff

Refresh the source registry and get the added/dropped columns.