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]),