Skip to main content

build_initial_add_mutation

risingwave_meta::barrier::checkpoint::independent_job

Function build_initial_add_mutation 

Source 
fn build_initial_add_mutation(
    fragment_infos: &HashMap<FragmentId, InflightFragmentInfo>,
    backfill_ordering: &ExtendedFragmentBackfillOrder,
    actor_splits: HashMap<ActorId, ConnectorSplits>,
) -> Mutation