-
Notifications
You must be signed in to change notification settings - Fork 1.9k
Open
Description
datafusion/datafusion/catalog/src/information_schema.rs
Lines 424 to 428 in 3ea21aa
| // only handle the function which implemented [`ScalarUDFImpl::return_type`] method | |
| let return_type = udf | |
| .return_type(&arg_types) | |
| .map(|t| remove_native_type_prefix(&NativeType::from(t))) | |
| .ok(); |
datafusion/datafusion/catalog/src/information_schema.rs
Lines 450 to 454 in 3ea21aa
| // only handle the function which implemented [`ScalarUDFImpl::return_type`] method | |
| let return_type = udaf | |
| .return_type(&arg_types) | |
| .ok() | |
| .map(|t| remove_native_type_prefix(&NativeType::from(t))); |
These should be using return_field_from_args as some UDFs/UDAFs/UDWFs implement that instead of return_type, especially since the default implementation of return_field_from_args already delegates to return_type
Metadata
Metadata
Assignees
Labels
No labels