build_stream_actors

risingwave_meta::barrier::context::recovery

Function build_stream_actors 

Source 
fn build_stream_actors(
    all_info: &FragmentRenderMap,
    job_extra_info: &HashMap<JobId, StreamingJobExtraInfo>,
) -> MetaResult<HashMap<ActorId, StreamActor>>
Expand description

Assembles StreamActor instances from rendered fragment info and job context.

This function combines the actor assignments from FragmentRenderMap with runtime context (timezone, config, definition) from StreamingJobExtraInfo to produce the final StreamActor structures needed for recovery.