fix

spiraldb · Nov 20, 2024 · 423b260 · 423b260
1 parent 912f691
commit 423b260
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datafusion/expr/src/expr_fn.rs b/datafusion/expr/src/expr_fn.rs
@@ -462,8 +462,8 @@ impl ScalarUDFImpl for SimpleScalarUDF {
         Ok(self.return_type.clone())
     }
 
-    fn invoke(&self, args: ScalarFunctionArgs) -> Result<ColumnarValue> {
-        (self.fun)(args.args.as_slice())
+    fn invoke_batch(&self, args: &[ColumnarValue], _number_rows: usize) -> Result<ColumnarValue> {
+        (self.fun)(args)
     }
 }