Skip to content

Commit cf16be4

Browse files
committed
Logging of meta plans
1 parent 5f7077c commit cf16be4

File tree

1 file changed

+3
-0
lines changed
  • rust/cubestore/cubestore/src/queryplanner

1 file changed

+3
-0
lines changed

rust/cubestore/cubestore/src/queryplanner/mod.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ pub mod serialized_plan;
1616
mod tail_limit;
1717
mod topk;
1818
pub mod trace_data_loaded;
19+
use pretty_printers::pp_phys_plan_ext;
1920
use rewrite_inlist_literals::RewriteInListLiterals;
2021
use serialized_plan::PreSerializedPlan;
2122
pub use topk::MIN_TOPK_STREAM_ROWS;
@@ -209,11 +210,13 @@ impl QueryPlanner for QueryPlannerImpl {
209210
}
210211

211212
async fn execute_meta_plan(&self, plan: LogicalPlan) -> Result<DataFrame, CubeError> {
213+
log::debug!("execute_meta_plan: {}", pp_plan_ext(&plan, &PPOptions{ show_filters: true, show_aggregations: true, ..PPOptions::none()}));
212214
let ctx = self.execution_context()?;
213215

214216
let plan_ctx = ctx.clone();
215217
let plan_to_move = plan.clone();
216218
let physical_plan = plan_ctx.state().create_physical_plan(&plan_to_move).await?;
219+
log::debug!("execute_meta_plan physical plan: {}", pp_phys_plan_ext(physical_plan.as_ref(), &PPOptions{ show_filters: true, show_sort_by: true, show_aggregations: true, show_output_hints: true, traverse_past_clustersend: true, ..PPOptions::none()}));
217220

218221
let execution_time = SystemTime::now();
219222
let results = collect(physical_plan, ctx.task_ctx()).await?;

0 commit comments

Comments
 (0)