Skip to main content

build_shuffle_receiver

Function build_shuffle_receiver 

Source
async fn build_shuffle_receiver(
    discovery: &DiscoveryImpl,
    node_id: NodeId,
) -> Result<Arc<ShuffleReceiver>, ClusterStartupError>
Expand description

Bind the ShuffleReceiver. When gossip discovery is active, publish the bound address under SHUFFLE_ADDR_KEY so peer senders can discover it on first send.