risingwave_meta::controller::utils

Function resolve_no_shuffle_actor_dispatcher

Source 
pub fn resolve_no_shuffle_actor_dispatcher(
    source_fragment_distribution: DistributionType,
    source_fragment_actors: &HashMap<ActorId, Option<Bitmap>>,
    target_fragment_distribution: DistributionType,
    target_fragment_actors: &HashMap<ActorId, Option<Bitmap>>,
) -> Vec<(ActorId, ActorId)>
Expand description

return (upstream_actor_id -> downstream_actor_id)