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