Skip to main content

group_v3_reports_by_sink

risingwave_meta::barrier::context::context_impl

Function group_v3_reports_by_sink 

Source 
fn group_v3_reports_by_sink(
    reports: Vec<PbIcebergV3SinkMetadata>,
) -> MetaResult<HashMap<SinkId, (u64, Vec<PbIcebergV3SinkMetadata>)>>