risingwave_batch::task

Module consistent_hash_shuffle_channel

Source

Structs§

ConsistentHashShuffleReceiver
ConsistentHashShuffleSender

Functions§

generate_hash_values 🔒
generate_new_data_chunks 🔒
The returned chunks must have cardinality > 0.
new_consistent_shuffle_channel