diff --git a/datafusion/expr/src/expr_fn.rs b/datafusion/expr/src/expr_fn.rs index 241d36eb6b6f..e08ac343e5af 100644 --- 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 { - (self.fun)(args.args.as_slice()) + fn invoke_batch(&self, args: &[ColumnarValue], _number_rows: usize) -> Result { + (self.fun)(args) } }