rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-10-13 15:32:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(function): rename uadf_impl to udf_impl in aggregate functions (#9482)

Browse Source 
refactor: rename uadf_impl to udf_impl in aggregate functions

Signed-off-by: fengyue-xve <1759519137@qq.com>
This commit is contained in:
fengyue-xve
2026-10-09 09:58:41 +00:00
committed by GitHub
parent 4ade13d9b6
commit f1a27ab599
7 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/common/function/src/aggrs/geo.rs
+2 -2
View File
@@ -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());
}
}
src/common/function/src/aggrs/geo/encoding.rs
+1 -1
View File
@@ -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
src/common/function/src/aggrs/geo/geo_path.rs
+1 -1
View File
@@ -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
src/common/function/src/aggrs/vector.rs
+3 -3
View File
@@ -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());
}
}
src/common/function/src/aggrs/vector/avg.rs
+1 -1
View File
@@ -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]),
src/common/function/src/aggrs/vector/product.rs
+1 -1
View File
@@ -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]),
src/common/function/src/aggrs/vector/sum.rs
+1 -1
View File
@@ -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]),