Renamed user_defined_sql_planners to expr_planners

datafusion/core/src/execution/context/mod.rs

@@ -1392,8 +1392,8 @@ impl FunctionRegistry for SessionContext {
         self.state.write().register_function_rewrite(rewrite)
     }
 
-    fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
-        self.state.read().user_defined_sql_planners()
+    fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
+        self.state.read().expr_planners()
     }
 
     fn register_user_defined_sql_planner(

datafusion/core/src/execution/session_state.rs

@@ -1183,7 +1183,7 @@ impl FunctionRegistry for SessionState {
         Ok(())
     }
 
-    fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
+    fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
         self.user_defined_sql_planners.clone()
     }
 

datafusion/core/tests/user_defined/user_defined_scalar_functions.rs

@@ -575,7 +575,7 @@ async fn test_user_defined_functions_cast_to_i64() -> Result<()> {
 async fn test_user_defined_sql_functions() -> Result<()> {
     let ctx = SessionContext::new();
 
-    let sql_planners = ctx.user_defined_sql_planners();
+    let sql_planners = ctx.expr_planners();
 
     assert!(!sql_planners.is_empty());
 

datafusion/execution/src/task.rs

@@ -192,7 +192,7 @@ impl FunctionRegistry for TaskContext {
         Ok(self.scalar_functions.insert(udf.name().into(), udf))
     }
 
-    fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
+    fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
         vec![]
     }
 }

datafusion/expr/src/registry.rs

@@ -111,7 +111,7 @@ pub trait FunctionRegistry {
     }
 
     /// Set of all registered [`UserDefinedSQLPlanner`]s
-    fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>>;
+    fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>>;
 
     /// Registers a new [`UserDefinedSQLPlanner`] with the registry.
     fn register_user_defined_sql_planner(
@@ -196,7 +196,7 @@ impl FunctionRegistry for MemoryFunctionRegistry {
         Ok(self.udwfs.insert(udaf.name().into(), udaf))
     }
 
-    fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
+    fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
         vec![]
     }
 }

datafusion/proto/src/bytes/mod.rs

@@ -167,7 +167,7 @@ impl Serializeable for Expr {
                 )
             }
 
-            fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
+            fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
                 vec![]
             }
         }

datafusion/proto/src/bytes/registry.rs

@@ -56,7 +56,7 @@ impl FunctionRegistry for NoRegistry {
         plan_err!("No function registry provided to deserialize, so can not deserialize User Defined Window Function '{}'", udwf.inner().name())
     }
 
-    fn user_defined_sql_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
+    fn expr_planners(&self) -> Vec<Arc<dyn UserDefinedSQLPlanner>> {
         vec![]
     }
 }