From fd37d4630c15b37e5d552f50674c18de9c804853 Mon Sep 17 00:00:00 2001 From: shuiyisong Date: Mon, 19 Jun 2023 17:59:57 +0800 Subject: [PATCH] chore: impl metrics method on df execution plan adapter --- src/common/query/src/physical_plan.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/common/query/src/physical_plan.rs b/src/common/query/src/physical_plan.rs index fd767a121e..05faf00d5d 100644 --- a/src/common/query/src/physical_plan.rs +++ b/src/common/query/src/physical_plan.rs @@ -203,6 +203,10 @@ impl DfPhysicalPlan for DfPhysicalPlanAdapter { Ok(Box::pin(DfRecordBatchStreamAdapter::new(stream))) } + fn metrics(&self) -> Option { + self.0.metrics() + } + fn statistics(&self) -> Statistics { Statistics::default() }