This is an automated email from the ASF dual-hosted git repository.
goldmedal pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 8f2f537633 chore: Migrate Encoding functions to invoke_with_args
(#14727)
8f2f537633 is described below
commit 8f2f5376337cc0b8efd73cee7f9cc0c519d51ed6
Author: irenjj <[email protected]>
AuthorDate: Tue Feb 18 20:25:03 2025 +0800
chore: Migrate Encoding functions to invoke_with_args (#14727)
---
datafusion/functions/src/encoding/inner.rs | 14 ++++++--------
1 file changed, 6 insertions(+), 8 deletions(-)
diff --git a/datafusion/functions/src/encoding/inner.rs
b/datafusion/functions/src/encoding/inner.rs
index 68a6d10060..51e8c69688 100644
--- a/datafusion/functions/src/encoding/inner.rs
+++ b/datafusion/functions/src/encoding/inner.rs
@@ -103,12 +103,11 @@ impl ScalarUDFImpl for EncodeFunc {
})
}
- fn invoke_batch(
+ fn invoke_with_args(
&self,
- args: &[ColumnarValue],
- _number_rows: usize,
+ args: datafusion_expr::ScalarFunctionArgs,
) -> Result<ColumnarValue> {
- encode(args)
+ encode(&args.args)
}
fn coerce_types(&self, arg_types: &[DataType]) -> Result<Vec<DataType>> {
@@ -183,12 +182,11 @@ impl ScalarUDFImpl for DecodeFunc {
Ok(arg_types[0].to_owned())
}
- fn invoke_batch(
+ fn invoke_with_args(
&self,
- args: &[ColumnarValue],
- _number_rows: usize,
+ args: datafusion_expr::ScalarFunctionArgs,
) -> Result<ColumnarValue> {
- decode(args)
+ decode(&args.args)
}
fn coerce_types(&self, arg_types: &[DataType]) -> Result<Vec<DataType>> {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
