Skip to main content

partition_resolver

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

Function partition_resolver 

Source 
pub(super) fn partition_resolver(
    rendered: RenderedIndependentJobActors,
    downstreams: &mut FragmentDownstreamRelation,
) -> MetaResult<(RenderedIndependentJobActors, RenderedResolver, IcebergV3FragmentPartition)>
Expand description

Split the dormant resolver from an Iceberg graph after actor placement and before edge construction. The complete relation map must be used during rendering so a no-shuffle resolver edge participates in actor alignment.