MCPcopy Create free account
hub / github.com/apache/datafusion / plan

Function plan

datafusion/core/src/physical_planner.rs:3263–3271  ·  view source on GitHub ↗
(logical_plan: &LogicalPlan)

Source from the content-addressed store, hash-verified

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?;

Callers 15

aggregate_explainFunction · 0.85
test_all_operatorsFunction · 0.85
test_create_cube_exprFunction · 0.85
test_create_rollup_exprFunction · 0.85
test_with_csv_planFunction · 0.85
hash_agg_input_schemaFunction · 0.85

Calls 3

make_session_stateFunction · 0.85
optimizeMethod · 0.45
create_physical_planMethod · 0.45

Tested by 10

test_all_operatorsFunction · 0.68
test_create_cube_exprFunction · 0.68
test_create_rollup_exprFunction · 0.68
test_with_csv_planFunction · 0.68
test_explainFunction · 0.68

Used in the wild real call sites across dependent graphs

searching dependent graphs…