Skip to main content

collect_region_watermarks

query::metrics

Function collect_region_watermarks 

Source 
fn collect_region_watermarks(
    plan: Arc<dyn ExecutionPlan>,
) -> Vec<RegionWatermarkEntry>