risingwave_meta::stream::source_manager

Function align_backfill_splits

source
fn align_backfill_splits(
    backfill_actors: impl IntoIterator<Item = (ActorId, Vec<ActorId>)>,
    upstream_assignment: &HashMap<ActorId, Vec<SplitImpl>>,
    fragment_id: FragmentId,
    upstream_fragment_id: FragmentId,
) -> Result<HashMap<ActorId, Vec<SplitImpl>>>