Exclude built-in scalar functions

viirya · Jan 29, 2024 · eaf4c11 · eaf4c11
1 parent e4f3638
commit eaf4c11
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/datafusion/physical-expr/src/scalar_function.rs b/datafusion/physical-expr/src/scalar_function.rs
@@ -153,7 +153,9 @@ impl PhysicalExpr for ScalarFunctionExpr {
             {
                 vec![ColumnarValue::create_null_array(batch.num_rows())]
             }
-            (0, _) if self.signature.type_signature.supports_zero_argument() => {
+            // If the function supports zero argument, we pass in a null array indicating the batch size.
+            // This is for user-defined functions.
+            (0, Err(_)) if self.signature.type_signature.supports_zero_argument() => {
                 vec![ColumnarValue::create_null_array(batch.num_rows())]
             }
             _ => self