(logical_plan: &LogicalPlan)
| 3261 | } |
| 3262 | |
| 3263 | async fn plan(logical_plan: &LogicalPlan) -> Result<Arc<dyn ExecutionPlan>> { |
| 3264 | let session_state = make_session_state(); |
| 3265 | // optimize the logical plan |
| 3266 | let logical_plan = session_state.optimize(logical_plan)?; |
| 3267 | let planner = DefaultPhysicalPlanner::default(); |
| 3268 | planner |
| 3269 | .create_physical_plan(&logical_plan, &session_state) |
| 3270 | .await |
| 3271 | } |
| 3272 | |
| 3273 | async fn aggregate_explain(logical_plan: &LogicalPlan) -> Result<String> { |
| 3274 | let physical_plan = plan(logical_plan).await?; |
searching dependent graphs…