risingwave_frontend::stream_fragmenter::rewrite::delta_join

Function dispatch_no_shuffle

Source 
fn dispatch_no_shuffle(output_indices: Vec<u32>) -> DispatchStrategy