Skip to content

Commit fdd6e7e

Browse files
committed
feat: add debug print statement in create_physical_plan and collect methods of DataFrame
1 parent a0b1a74 commit fdd6e7e

File tree

1 file changed

+1
-1
lines changed
  • datafusion/core/src/dataframe

1 file changed

+1
-1
lines changed

datafusion/core/src/dataframe/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,6 +215,7 @@ impl DataFrame {
215215

216216
/// Consume the DataFrame and produce a physical plan
217217
pub async fn create_physical_plan(self) -> Result<Arc<dyn ExecutionPlan>> {
218+
println!("==> create_physical_plan {:?}", &self.plan);
218219
self.session_state.create_physical_plan(&self.plan).await
219220
}
220221

@@ -1206,7 +1207,6 @@ impl DataFrame {
12061207
println!("==> dataframe.collect");
12071208
let task_ctx = Arc::new(self.task_ctx());
12081209
let plan = self.create_physical_plan().await?;
1209-
println!("==> dataframe.collect plan: {:?}", plan);
12101210
collect(plan, task_ctx).await
12111211
}
12121212

0 commit comments

Comments
 (0)