File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -118,10 +118,6 @@ pub fn create_physical_expr(
118118 let idx = input_dfschema. index_of_column ( c) ?;
119119 Ok ( Arc :: new ( Column :: new ( & c. name , idx) ) )
120120 }
121- Expr :: OuterReferenceColumn ( _datatype, c) => {
122- let idx = input_dfschema. index_of_column ( c) ?;
123- Ok ( Arc :: new ( Column :: new ( & c. name , idx) ) )
124- }
125121 Expr :: Literal ( value) => Ok ( Arc :: new ( Literal :: new ( value. clone ( ) ) ) ) ,
126122 Expr :: ScalarVariable ( _, variable_names) => {
127123 if is_system_variables ( variable_names) {
Original file line number Diff line number Diff line change @@ -403,7 +403,7 @@ impl<S: ContextProvider> SqlToRel<'_, S> {
403403 TableFactor :: Function {
404404 name, args, alias, ..
405405 } => {
406- let tbl_func_name = self . object_name_to_table_reference ( name) ?;
406+ let tbl_func_ref = self . object_name_to_table_reference ( name) ?;
407407 let schema = planner_context
408408 . outer_query_schema ( )
409409 . cloned ( )
@@ -434,10 +434,10 @@ impl<S: ContextProvider> SqlToRel<'_, S> {
434434 _ => plan_err ! ( "Unsupported function argument: {arg:?}" ) ,
435435 } )
436436 . collect :: < Result < Vec < ( Expr , Option < String > ) > > > ( ) ?;
437-
437+ let tbl_func_name = tbl_func_ref . table ( ) . to_ascii_lowercase ( ) ;
438438 let provider = self
439439 . context_provider
440- . get_table_function_source ( tbl_func_name. table ( ) , func_args) ?;
440+ . get_table_function_source ( & tbl_func_name, func_args) ?;
441441 let plan =
442442 LogicalPlanBuilder :: scan ( tbl_func_name, provider, None ) ?. build ( ) ?;
443443 ( plan, alias)
You can’t perform that action at this time.
0 commit comments