Module additional_columns

Source

Statics§

CDC_BACKFILL_TABLE_ADDITIONAL_COLUMNS
COMMON_COMPATIBLE_ADDITIONAL_COLUMNS
COMPATIBLE_ADDITIONAL_COLUMNS

Functions§

build_additional_column_desc
build_header_catalog 🔒
gen_default_addition_col_name
get_kafka_header_item_datatype
get_supported_additional_columns
source_add_partition_offset_cols
Utility function for adding partition and offset columns to the columns, if not specified by the user.