Module scale

Structs§

ActorGraph
LoadedFragmentContext: Context loaded asynchronously from database, containing all metadata required to render actor assignments. This separates async I/O from sync rendering logic.
NoShuffleEnsemble
RenderActorsContext 🔒
RenderedGraph
TargetResourcePolicy
WorkerInfo

build_loaded_context 🔒
debug_sanity_check 🔒
find_fragment_no_shuffle_dags_detailed
find_no_shuffle_graphs 🔒
load_fragment_context: Async load stage for fragment-scoped rendering. It resolves all metadata required to later render actor assignments with arbitrary worker sets.
load_fragment_context_for_jobs: Async load stage for job-scoped rendering. It collects all no-shuffle ensembles and the metadata required to render actor assignments later with a provided worker set.
load_fragment_info
render_actor_assignments 🔒: Sync render stage: uses loaded fragment context and current worker info to produce actor-to-worker assignments and vnode bitmaps.
render_actors 🔒
render_fragments: Fragment-scoped rendering entry point used by operational tooling. It validates that the requested fragments are roots of their no-shuffle ensembles, resolves only the metadata required for those components, and then reuses the shared rendering pipeline to materialize actor assignments.
render_jobs: Job-scoped rendering entry point that walks every no-shuffle root belonging to the provided streaming jobs before delegating to the shared rendering backend.
resolve_source_fragments 🔒
resolve_streaming_job_definition 🔒