Skip to main content

datafusion_distributed/metrics/
mod.rs

1mod bytes_metric;
2mod latency_metric;
3mod max_gauge_metric;
4pub(crate) mod proto;
5mod task_metrics_collector;
6mod task_metrics_rewriter;
7
8pub use bytes_metric::{BytesCounterMetric, BytesMetricExt};
9pub use latency_metric::{
10    AvgLatencyMetric, FirstLatencyMetric, LatencyMetricExt, MaxLatencyMetric, MinLatencyMetric,
11    P50LatencyMetric, P75LatencyMetric, P95LatencyMetric, P99LatencyMetric,
12};
13pub use max_gauge_metric::{GaugeMetricExt, MaxGaugeMetric};
14pub(crate) use task_metrics_collector::collect_plan_metrics;
15pub use task_metrics_rewriter::{DistributedMetricsFormat, rewrite_distributed_plan_with_metrics};
16/// Label used to annotate metrics in execution plan nodes with the task in which they were executed.
17/// Note that the same task id may be used in multiple stages.
18pub const DISTRIBUTED_DATAFUSION_TASK_ID_LABEL: &str = "task_id";