remove stream api

zhangstar333 · May 22, 2024 · 509efa6 · 509efa6
1 parent f1b6021
commit 509efa6
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/...core/src/main/java/org/apache/doris/nereids/rules/implementation/AggregateStrategies.java b/...core/src/main/java/org/apache/doris/nereids/rules/implementation/AggregateStrategies.java
@@ -82,6 +82,7 @@
 import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 
+import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
@@ -333,16 +334,17 @@ private LogicalProject<? extends Plan> pushDownCountWithoutSlotRef(
                 return canNotPush;
             }
         }
-        List<Expression> projectExpr = project.getProjects()
-                .stream()
-                .flatMap(p -> Project.collectExpressions(p).stream())
-                .collect(ImmutableList.toImmutableList());
-        boolean noSlotRef = projectExpr.stream().allMatch(expr -> {
+        List<Expression> projectExpr = new ArrayList<>();
+        for (Expression p : project.getProjects()) {
+            projectExpr.addAll(Project.collectExpressions(p));
+        }
+        boolean noSlotRef = true;
+        for (Expression expr : projectExpr) {
             if (expr instanceof SlotReference) {
-                return false;
+                noSlotRef = false;
+                break;
             }
-            return true;
-        });
+        }
         if (!noSlotRef) {
             return canNotPush;
         }