Skip to main content

build_transition

risingwave_meta::barrier::checkpoint::independent_job::iceberg_v3_job::render

Function build_transition 

Source 
fn build_transition(
    stopping_fragment_ids: &HashSet<FragmentId>,
    starting_fragment_ids: &HashSet<FragmentId>,
    long_running_fragment_ids: &HashSet<FragmentId>,
    fragment_infos: &HashMap<FragmentId, &InflightFragmentInfo>,
    stream_actors: &HashMap<FragmentId, &[StreamActor]>,
    downstreams: &FragmentDownstreamRelation,
    partial_graph_id: PartialGraphId,
    control_stream_manager: &ControlStreamManager,
) -> MetaResult<CompactionTransition>