Skip to main content

group_reports_by_sink

risingwave_meta::barrier::context::context_impl

Function group_reports_by_sink 

Source 
fn group_reports_by_sink(
    reports: Vec<PbIcebergPkIndexSinkMetadata>,
) -> MetaResult<HashMap<SinkId, (u64, Vec<PbIcebergPkIndexSinkMetadata>)>>