risingwave_batch::task::hash_shuffle_channel

Function generate_new_data_chunks

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

The returned chunks must have cardinality > 0.