From 27d0bdf1ff543d181053607a985c5c94f326eb94 Mon Sep 17 00:00:00 2001 From: jackwener Date: Sat, 29 Oct 2022 20:50:28 +0800 Subject: [PATCH 1/2] Support SubqueryAlias wrap filter. --- datafusion/core/src/physical_plan/planner.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/datafusion/core/src/physical_plan/planner.rs b/datafusion/core/src/physical_plan/planner.rs index a389bb65bdc7e..cec29bf0dd3c1 100644 --- a/datafusion/core/src/physical_plan/planner.rs +++ b/datafusion/core/src/physical_plan/planner.rs @@ -1013,6 +1013,9 @@ impl DefaultPhysicalPlanner { LogicalPlan::TableScan(..) => { self.create_initial_plan(input, session_state).await } + LogicalPlan::Filter(..) => { + self.create_initial_plan(input, session_state).await + } _ => Err(DataFusionError::Plan("SubqueryAlias should only wrap TableScan".to_string())) } } From 940ef73c3008b6cf9548b11e61ef2a75b3567263 Mon Sep 17 00:00:00 2001 From: jackwener Date: Sat, 29 Oct 2022 22:30:27 +0800 Subject: [PATCH 2/2] polish Err --- datafusion/core/src/physical_plan/planner.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datafusion/core/src/physical_plan/planner.rs b/datafusion/core/src/physical_plan/planner.rs index cec29bf0dd3c1..73ecd5bf753d1 100644 --- a/datafusion/core/src/physical_plan/planner.rs +++ b/datafusion/core/src/physical_plan/planner.rs @@ -1016,7 +1016,7 @@ impl DefaultPhysicalPlanner { LogicalPlan::Filter(..) => { self.create_initial_plan(input, session_state).await } - _ => Err(DataFusionError::Plan("SubqueryAlias should only wrap TableScan".to_string())) + _ => Err(DataFusionError::Plan("SubqueryAlias should only wrap TableScan or Filter".to_string())) } } LogicalPlan::Limit(Limit { input, skip, fetch, .. }) => {