risingwave_frontend::handler::alter_table_column

Function hijack_merger_for_target_table

Source 
pub(crate) fn hijack_merger_for_target_table(
    graph: &mut StreamFragmentGraph,
    target_columns: &[ColumnCatalog],
    sink: &SinkCatalog,
    uniq_identify: Option<&str>,
) -> Result<(), RwError>