Skip to main content

datafusion_distributed/metrics/
mod.rs

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