From f1a27ab599a615362aceaaea913ea3ce91879bfe Mon Sep 17 00:00:00 2001
From: fengyue-xve <1759519137@qq.com>
Date: Fri, 9 Oct 2026 09:58:41 +0000
Subject: [PATCH] refactor(function): rename uadf_impl to udf_impl in aggregate
 functions (#9482)

refactor: rename uadf_impl to udf_impl in aggregate functions

Signed-off-by: fengyue-xve <1759519137@qq.com>
---
 src/common/function/src/aggrs/geo.rs            | 4 ++--
 src/common/function/src/aggrs/geo/encoding.rs   | 2 +-
 src/common/function/src/aggrs/geo/geo_path.rs   | 2 +-
 src/common/function/src/aggrs/vector.rs         | 6 +++---
 src/common/function/src/aggrs/vector/avg.rs     | 2 +-
 src/common/function/src/aggrs/vector/product.rs | 2 +-
 src/common/function/src/aggrs/vector/sum.rs     | 2 +-
 7 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/src/common/function/src/aggrs/geo.rs b/src/common/function/src/aggrs/geo.rs
index c76fe7348f2..abe9070a0a0 100644
--- a/src/common/function/src/aggrs/geo.rs
+++ b/src/common/function/src/aggrs/geo.rs
@@ -21,7 +21,7 @@ pub(crate) struct GeoFunction;
 
 impl GeoFunction {
     pub fn register(registry: &FunctionRegistry) {
-        registry.register_aggr(encoding::JsonEncodePathAccumulator::uadf_impl());
-        registry.register_aggr(geo_path::GeoPathAccumulator::uadf_impl());
+        registry.register_aggr(encoding::JsonEncodePathAccumulator::udf_impl());
+        registry.register_aggr(geo_path::GeoPathAccumulator::udf_impl());
     }
 }
diff --git a/src/common/function/src/aggrs/geo/encoding.rs b/src/common/function/src/aggrs/geo/encoding.rs
index 67dfd493a77..5b4591bb6d8 100644
--- a/src/common/function/src/aggrs/geo/encoding.rs
+++ b/src/common/function/src/aggrs/geo/encoding.rs
@@ -47,7 +47,7 @@ impl JsonEncodePathAccumulator {
         Self::default()
     }
 
-    pub fn uadf_impl() -> AggregateUDF {
+    pub fn udf_impl() -> AggregateUDF {
         create_udaf(
             JSON_ENCODE_PATH_NAME,
             // Input types: lat, lng, timestamp
diff --git a/src/common/function/src/aggrs/geo/geo_path.rs b/src/common/function/src/aggrs/geo/geo_path.rs
index c4e366c83b0..fe8d8bae21c 100644
--- a/src/common/function/src/aggrs/geo/geo_path.rs
+++ b/src/common/function/src/aggrs/geo/geo_path.rs
@@ -47,7 +47,7 @@ impl GeoPathAccumulator {
         Self::default()
     }
 
-    pub fn uadf_impl() -> AggregateUDF {
+    pub fn udf_impl() -> AggregateUDF {
         create_udaf(
             GEO_PATH_NAME,
             // Input types: lat, lng, timestamp
diff --git a/src/common/function/src/aggrs/vector.rs b/src/common/function/src/aggrs/vector.rs
index 03489a51d44..0c0c70f7360 100644
--- a/src/common/function/src/aggrs/vector.rs
+++ b/src/common/function/src/aggrs/vector.rs
@@ -25,8 +25,8 @@ pub(crate) struct VectorFunction;
 
 impl VectorFunction {
     pub fn register(registry: &FunctionRegistry) {
-        registry.register_aggr(VectorSum::uadf_impl());
-        registry.register_aggr(VectorProduct::uadf_impl());
-        registry.register_aggr(VectorAvg::uadf_impl());
+        registry.register_aggr(VectorSum::udf_impl());
+        registry.register_aggr(VectorProduct::udf_impl());
+        registry.register_aggr(VectorAvg::udf_impl());
     }
 }
diff --git a/src/common/function/src/aggrs/vector/avg.rs b/src/common/function/src/aggrs/vector/avg.rs
index 82e6a28059f..a8af8cf6d0c 100644
--- a/src/common/function/src/aggrs/vector/avg.rs
+++ b/src/common/function/src/aggrs/vector/avg.rs
@@ -39,7 +39,7 @@ pub struct VectorAvg {
 
 impl VectorAvg {
     /// Create a new `AggregateUDF` for the `vec_avg` aggregate function.
-    pub fn uadf_impl() -> AggregateUDF {
+    pub fn udf_impl() -> AggregateUDF {
         let signature = Signature::one_of(
             vec![
                 TypeSignature::Exact(vec![DataType::Utf8]),
diff --git a/src/common/function/src/aggrs/vector/product.rs b/src/common/function/src/aggrs/vector/product.rs
index 8178b74f369..4f0e9bb6217 100644
--- a/src/common/function/src/aggrs/vector/product.rs
+++ b/src/common/function/src/aggrs/vector/product.rs
@@ -39,7 +39,7 @@ pub struct VectorProduct {
 
 impl VectorProduct {
     /// Create a new `AggregateUDF` for the `vec_product` aggregate function.
-    pub fn uadf_impl() -> AggregateUDF {
+    pub fn udf_impl() -> AggregateUDF {
         let signature = Signature::one_of(
             vec![
                 TypeSignature::Exact(vec![DataType::Utf8]),
diff --git a/src/common/function/src/aggrs/vector/sum.rs b/src/common/function/src/aggrs/vector/sum.rs
index b1b68906ded..466fc42cccb 100644
--- a/src/common/function/src/aggrs/vector/sum.rs
+++ b/src/common/function/src/aggrs/vector/sum.rs
@@ -39,7 +39,7 @@ pub struct VectorSum {
 
 impl VectorSum {
     /// Create a new `AggregateUDF` for the `vec_sum` aggregate function.
-    pub fn uadf_impl() -> AggregateUDF {
+    pub fn udf_impl() -> AggregateUDF {
         let signature = Signature::one_of(
             vec![
                 TypeSignature::Exact(vec![DataType::Utf8]),