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