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

[fix](compile)fix compile failed after merge #11117 #10479 and #11162 (#11253)

Browse Source 
fix the compile failed after merge #11117 #10479 and #11162
This commit is contained in:
morrySnow
2022-07-27 17:25:06 +08:00
committed by GitHub
parent be2ac6aa59
commit 42d76b54dc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/logical/PushPredicateThroughAggregation.java
View File

@ -70,14 +70,14 @@ public class PushPredicateThroughAggregation extends OneRewriteRuleFactory {
return logicalFilter(logicalAggregate()).then(filter -> {
LogicalAggregate<GroupPlan> aggregate = filter.child();
Set<Slot> groupBySlots = new HashSet<>();
for (Expression groupByExpression : aggregate.getGroupByExpressionList()) {
for (Expression groupByExpression : aggregate.getGroupByExpressions()) {
if (groupByExpression instanceof Slot) {
groupBySlots.add((Slot) groupByExpression);
}
}
List<Expression> pushDownPredicates = Lists.newArrayList();
List<Expression> filterPredicates = Lists.newArrayList();
ExpressionUtils.extractConjunct(filter.getPredicates()).forEach(conjunct -> {
ExpressionUtils.extractConjunctive(filter.getPredicates()).forEach(conjunct -> {
Set<Slot> conjunctSlots = SlotExtractor.extractSlot(conjunct);
if (groupBySlots.containsAll(conjunctSlots)) {
pushDownPredicates.add(conjunct);