risingwave_frontend::stream_fragmenter::rewrite::delta_join

Function dispatch_no_shuffle

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