From 42d76b54dc2912308d74f2cd5ae430fc48768cb7 Mon Sep 17 00:00:00 2001 From: morrySnow <101034200+morrySnow@users.noreply.github.com> Date: Wed, 27 Jul 2022 17:25:06 +0800 Subject: [PATCH] [fix](compile)fix compile failed after merge #11117 #10479 and #11162 (#11253) fix the compile failed after merge #11117 #10479 and #11162 --- .../rewrite/logical/PushPredicateThroughAggregation.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/logical/PushPredicateThroughAggregation.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/logical/PushPredicateThroughAggregation.java index bc4155bdec..d2e2912437 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/logical/PushPredicateThroughAggregation.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/logical/PushPredicateThroughAggregation.java @@ -70,14 +70,14 @@ public class PushPredicateThroughAggregation extends OneRewriteRuleFactory { return logicalFilter(logicalAggregate()).then(filter -> { LogicalAggregate aggregate = filter.child(); Set groupBySlots = new HashSet<>(); - for (Expression groupByExpression : aggregate.getGroupByExpressionList()) { + for (Expression groupByExpression : aggregate.getGroupByExpressions()) { if (groupByExpression instanceof Slot) { groupBySlots.add((Slot) groupByExpression); } } List pushDownPredicates = Lists.newArrayList(); List filterPredicates = Lists.newArrayList(); - ExpressionUtils.extractConjunct(filter.getPredicates()).forEach(conjunct -> { + ExpressionUtils.extractConjunctive(filter.getPredicates()).forEach(conjunct -> { Set conjunctSlots = SlotExtractor.extractSlot(conjunct); if (groupBySlots.containsAll(conjunctSlots)) { pushDownPredicates.add(conjunct);