(
&self,
expr: SQLExpr,
fn_name: &str,
schema: &DFSchema,
planner_context: &mut PlannerContext,
)
| 956 | } |
| 957 | |
| 958 | pub(super) fn sql_fn_name_to_expr( |
| 959 | &self, |
| 960 | expr: SQLExpr, |
| 961 | fn_name: &str, |
| 962 | schema: &DFSchema, |
| 963 | planner_context: &mut PlannerContext, |
| 964 | ) -> Result<Expr> { |
| 965 | let fun = self |
| 966 | .context_provider |
| 967 | .get_function_meta(fn_name) |
| 968 | .ok_or_else(|| { |
| 969 | internal_datafusion_err!("Unable to find expected '{fn_name}' function") |
| 970 | })?; |
| 971 | let args = vec![self.sql_expr_to_logical_expr(expr, schema, planner_context)?]; |
| 972 | Ok(Expr::ScalarFunction(ScalarFunction::new_udf(fun, args))) |
| 973 | } |
| 974 | |
| 975 | pub(super) fn find_window_func( |
| 976 | &self, |
no test coverage detected