risingwave_batch::task::consistent_hash_shuffle_channel

Function generate_hash_values

Source 
fn generate_hash_values(
    chunk: &DataChunk,
    consistent_hash_info: &ConsistentHashInfo,
) -> Result<Vec<usize>>