Skip to main content

maybe_attach_region_watermark_metrics

query::metrics

Function maybe_attach_region_watermark_metrics 

Source 
pub fn maybe_attach_region_watermark_metrics(
    stream: SendableRecordBatchStream,
    plan: Arc<dyn ExecutionPlan>,
    should_collect_region_watermark: bool,
) -> SendableRecordBatchStream
Expand description

Attaches terminal region watermark metrics to stream when collection is requested.