risingwave_batch::task::consistent_hash_shuffle_channel

Function generate_new_data_chunks

source 
fn generate_new_data_chunks(
    chunk: &DataChunk,
    output_count: usize,
    hash_values: &[usize],
) -> Vec<DataChunk>
Expand description

The returned chunks must have cardinality > 0.