extend_sink_columns

risingwave_meta::stream::stream_graph::fragment

Function extend_sink_columns 

Source 
fn extend_sink_columns(
    sink_columns: &mut Vec<PbColumnCatalog>,
    new_columns: &[ColumnCatalog],
    get_column_name: impl Fn(&String) -> String,
)
Expand description

Append new columns to a sink/log-store column list with updated names/ids.