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