diff --git a/datafusion/core/src/execution/session_state_defaults.rs b/datafusion/core/src/execution/session_state_defaults.rs index 91722a00c430..b7e7b5f0955f 100644 --- a/datafusion/core/src/execution/session_state_defaults.rs +++ b/datafusion/core/src/execution/session_state_defaults.rs @@ -84,7 +84,7 @@ impl SessionStateDefaults { Arc::new(functions::core::planner::CoreFunctionPlanner::default()), // register crate of nested expressions (if enabled) #[cfg(feature = "nested_expressions")] - Arc::new(functions_nested::planner::ArrayFunctionPlanner), + Arc::new(functions_nested::planner::NestedFunctionPlanner), #[cfg(feature = "nested_expressions")] Arc::new(functions_nested::planner::FieldAccessPlanner), #[cfg(any( diff --git a/datafusion/functions-nested/benches/map.rs b/datafusion/functions-nested/benches/map.rs index 77f1765157cb..c9a12eefa4fa 100644 --- a/datafusion/functions-nested/benches/map.rs +++ b/datafusion/functions-nested/benches/map.rs @@ -29,7 +29,7 @@ use datafusion_common::ScalarValue; use datafusion_expr::planner::ExprPlanner; use datafusion_expr::{ColumnarValue, Expr}; use datafusion_functions_nested::map::map_udf; -use datafusion_functions_nested::planner::ArrayFunctionPlanner; +use datafusion_functions_nested::planner::NestedFunctionPlanner; fn keys(rng: &mut ThreadRng) -> Vec { let mut keys = vec![]; @@ -58,7 +58,7 @@ fn criterion_benchmark(c: &mut Criterion) { buffer.push(Expr::Literal(ScalarValue::Int32(Some(values[i])))); } - let planner = ArrayFunctionPlanner {}; + let planner = NestedFunctionPlanner {}; b.iter(|| { black_box( diff --git a/datafusion/functions-nested/src/planner.rs b/datafusion/functions-nested/src/planner.rs index c63c2c83e66e..9ffd2a609d49 100644 --- a/datafusion/functions-nested/src/planner.rs +++ b/datafusion/functions-nested/src/planner.rs @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -//! SQL planning extensions like [`ArrayFunctionPlanner`] and [`FieldAccessPlanner`] +//! SQL planning extensions like [`NestedFunctionPlanner`] and [`FieldAccessPlanner`] use datafusion_common::{exec_err, utils::list_ndims, DFSchema, Result}; use datafusion_expr::expr::ScalarFunction; @@ -35,9 +35,9 @@ use crate::{ make_array::make_array, }; -pub struct ArrayFunctionPlanner; +pub struct NestedFunctionPlanner; -impl ExprPlanner for ArrayFunctionPlanner { +impl ExprPlanner for NestedFunctionPlanner { fn plan_binary_op( &self, expr: RawBinaryExpr,