Module additional_columns

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.