Struct RenderedIndependentJobActors 

pub(crate) struct RenderedIndependentJobActors {
    pub fragment_infos: HashMap<FragmentId, InflightFragmentInfo>,
    pub stream_actors: HashMap<FragmentId, Vec<StreamActor>>,
}

Static actor metadata rendered for a closed independent-job graph.

This does not build edges or decide which fragments are active. In particular, Iceberg V3 can render all of its actor partitions once and activate only the input or compaction-resolver partition for a given phase.

Fields

fragment_infos: HashMap<FragmentId, InflightFragmentInfo>

stream_actors: HashMap<FragmentId, Vec<StreamActor>>

Implementations

impl RenderedIndependentJobActors

Render actor IDs, placement, vnode bitmaps, and actor definitions for a closed independent-job graph.

Every fragment in a no-shuffle ensemble must belong to fragments. Independent jobs consume upstream data through the log store, so their actor placement does not need to align with an existing upstream fragment.

pub(crate) fn render( fragments: &HashMap<FragmentId, LoadedFragment>, downstreams: &FragmentDownstreamRelation, definition: &str, actor_id_generator: &AtomicU32, worker_nodes: &HashMap<WorkerId, WorkerNode>, database_resource_group: &str, streaming_job_model: &Model, ) -> MetaResult<Self>

pub(crate) fn build_job_info( self, downstreams: &FragmentDownstreamRelation, partial_graph_id: PartialGraphId, control_stream_manager: &ControlStreamManager, ) -> MetaResult<BatchRefreshRenderResult>

Build the runtime information for the active part of an already-rendered independent job.

Keeping this separate from Self::render lets jobs with dormant fragments partition the rendered graph before any runtime edges are connected.

Trait Implementations

impl Debug for RenderedIndependentJobActors

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.