This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 7665c078e12 [opt](Nereids) ignore distinct for some aggregate
functions (#51088)
7665c078e12 is described below
commit 7665c078e1272d6286ce4c1c3ac865e74dc597d7
Author: morrySnow <zhangwen...@selectdb.com>
AuthorDate: Thu May 22 14:58:19 2025 +0800
[opt](Nereids) ignore distinct for some aggregate functions (#51088)
- any_value
- bitmap_agg
- collect_set
- group_bit_and
- group_bit_or
---
.../doris/nereids/trees/expressions/functions/agg/AnyValue.java | 4 ++--
.../doris/nereids/trees/expressions/functions/agg/BitmapAgg.java | 2 +-
.../doris/nereids/trees/expressions/functions/agg/CollectSet.java | 4 ++--
.../doris/nereids/trees/expressions/functions/agg/GroupBitAnd.java | 2 +-
.../doris/nereids/trees/expressions/functions/agg/GroupBitOr.java | 2 +-
5 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/AnyValue.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/AnyValue.java
index e85c2ce551c..e9726ff9ff2 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/AnyValue.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/AnyValue.java
@@ -54,8 +54,8 @@ public class AnyValue extends NullableAggregateFunction
this(distinct, false, arg);
}
- public AnyValue(boolean distinct, boolean alwaysNullable, Expression arg) {
- super("any_value", distinct, alwaysNullable, arg);
+ private AnyValue(boolean distinct, boolean alwaysNullable, Expression arg)
{
+ super("any_value", false, alwaysNullable, arg);
}
/**
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/BitmapAgg.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/BitmapAgg.java
index a0eaf88efaf..eb20c60fc9c 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/BitmapAgg.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/BitmapAgg.java
@@ -50,7 +50,7 @@ public class BitmapAgg extends NotNullableAggregateFunction
}
public BitmapAgg(boolean distinct, Expression arg0) {
- super("bitmap_agg", distinct, arg0);
+ this(arg0);
}
@Override
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/CollectSet.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/CollectSet.java
index 2aba485fc7d..0f3ba304166 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/CollectSet.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/CollectSet.java
@@ -64,14 +64,14 @@ public class CollectSet extends NotNullableAggregateFunction
* constructor with 1 argument.
*/
public CollectSet(boolean distinct, Expression arg) {
- super("collect_set", distinct, arg);
+ this(arg);
}
/**
* constructor with 1 argument.
*/
public CollectSet(boolean distinct, Expression arg0, Expression arg1) {
- super("collect_set", distinct, arg0, arg1);
+ this(arg0, arg1);
}
@Override
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitAnd.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitAnd.java
index eece53f2a58..0e7488d2308 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitAnd.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitAnd.java
@@ -62,7 +62,7 @@ public class GroupBitAnd extends NullableAggregateFunction
}
private GroupBitAnd(boolean distinct, boolean alwaysNullable, Expression
child) {
- super("group_bit_and", distinct, alwaysNullable, child);
+ super("group_bit_and", false, alwaysNullable, child);
}
/**
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitOr.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitOr.java
index 35ba1597259..ce6a696bfa7 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitOr.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/GroupBitOr.java
@@ -63,7 +63,7 @@ public class GroupBitOr extends NullableAggregateFunction
}
private GroupBitOr(boolean distinct, boolean alwaysNullable, Expression
child) {
- super("group_bit_or", distinct, alwaysNullable, child);
+ super("group_bit_or", false, alwaysNullable, child);
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
