risingwave_frontend::handler::create_source

Function handle_addition_columns

source 
pub fn handle_addition_columns(
    format_encode: Option<&FormatEncodeOptions>,
    with_properties: &BTreeMap<String, String>,
    additional_columns: IncludeOption,
    columns: &mut Vec<ColumnCatalog>,
    is_cdc_backfill_table: bool,
) -> Result<(), RwError>
Expand description

add connector-spec columns to the end of column catalog