Add get_dal_metrics to query/context
@@ -27,6 +27,7 @@ use common_base::ProgressValues;
use common_base::Runtime;
use common_base::TrySpawn;
use common_dal::AzureBlobAccessor;
+use common_dal::DalMetrics;
use common_dal::DataAccessor;
use common_dal::DataAccessorInterceptor;
use common_dal::Local;
@@ -290,6 +291,11 @@ impl DatabendQueryContext {
da,
)))
}
+
+ /// Get the data accessor metrics.
+ pub fn get_dal_metrics(&self) -> DalMetrics {
+ self.shared.dal_ctx.get_metrics()
+ }
}
impl TrySpawn for DatabendQueryContext {
