database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](Nereids) aggregate combinator should be case-insensitive (#35540)

Browse Source
This commit is contained in:
morrySnow
2024-05-29 11:36:57 +08:00
committed by yiguolei
parent 6fd3916168
commit f076fe8624
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/AggCombinerFunctionBuilder.java
View File

@ -63,8 +63,8 @@ public class AggCombinerFunctionBuilder extends FunctionBuilder {
}
@Override
public boolean canApply(List<? extends Object> arguments) {
if (combinatorSuffix.equals(STATE) || combinatorSuffix.equals(FOREACH)) {
public boolean canApply(List<?> arguments) {
if (combinatorSuffix.equalsIgnoreCase(STATE) || combinatorSuffix.equalsIgnoreCase(FOREACH)) {
return nestedBuilder.canApply(arguments);
} else {
if (arguments.size() != 1) {
@ -123,18 +123,18 @@ public class AggCombinerFunctionBuilder extends FunctionBuilder {
}
@Override
public Pair<BoundFunction, AggregateFunction> build(String name, List<? extends Object> arguments) {
public Pair<BoundFunction, AggregateFunction> build(String name, List<?> arguments) {
String nestedName = getNestedName(name);
if (combinatorSuffix.equals(STATE)) {
if (combinatorSuffix.equalsIgnoreCase(STATE)) {
AggregateFunction nestedFunction = buildState(nestedName, arguments);
return Pair.of(new StateCombinator((List<Expression>) arguments, nestedFunction), nestedFunction);
} else if (combinatorSuffix.equals(MERGE)) {
} else if (combinatorSuffix.equalsIgnoreCase(MERGE)) {
AggregateFunction nestedFunction = buildMergeOrUnion(nestedName, arguments);
return Pair.of(new MergeCombinator((List<Expression>) arguments, nestedFunction), nestedFunction);
} else if (combinatorSuffix.equals(UNION)) {
} else if (combinatorSuffix.equalsIgnoreCase(UNION)) {
AggregateFunction nestedFunction = buildMergeOrUnion(nestedName, arguments);
return Pair.of(new UnionCombinator((List<Expression>) arguments, nestedFunction), nestedFunction);
} else if (combinatorSuffix.equals(FOREACH)) {
} else if (combinatorSuffix.equalsIgnoreCase(FOREACH)) {
AggregateFunction nestedFunction = buildForEach(nestedName, arguments);
return Pair.of(new ForEachCombinator((List<Expression>) arguments, nestedFunction), nestedFunction);
}