risingwave_frontend::stream_fragmenter::rewrite::delta_join

Function dispatch_consistent_hash_shuffle

Source 
fn dispatch_consistent_hash_shuffle(
    dist_key_indices: Vec<u32>,
    output_indices: Vec<u32>,
) -> DispatchStrategy