risingwave_frontend::handler::create_sink

Function insert_merger_to_union_with_project

Source 
pub(crate) fn insert_merger_to_union_with_project(
    node: &mut StreamNode,
    project_node: &PbNodeBody,
    uniq_identity: Option<&str>,
)