revert rules

apache · Nov 23, 2023 · aca4122 · aca4122
1 parent 06f1201
commit aca4122
Showing 1 changed file with 8 additions and 12 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/executor/Rewriter.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/jobs/executor/Rewriter.java
@@ -91,13 +91,9 @@
 import org.apache.doris.nereids.rules.rewrite.PullUpProjectUnderTopN;
 import org.apache.doris.nereids.rules.rewrite.PushConjunctsIntoEsScan;
 import org.apache.doris.nereids.rules.rewrite.PushConjunctsIntoJdbcScan;
-import org.apache.doris.nereids.rules.rewrite.PushDownCountThroughJoin;
-import org.apache.doris.nereids.rules.rewrite.PushDownDistinctThroughJoin;
 import org.apache.doris.nereids.rules.rewrite.PushDownFilterThroughProject;
 import org.apache.doris.nereids.rules.rewrite.PushDownLimit;
 import org.apache.doris.nereids.rules.rewrite.PushDownLimitDistinctThroughJoin;
-import org.apache.doris.nereids.rules.rewrite.PushDownMinMaxThroughJoin;
-import org.apache.doris.nereids.rules.rewrite.PushDownSumThroughJoin;
 import org.apache.doris.nereids.rules.rewrite.PushDownTopNThroughJoin;
 import org.apache.doris.nereids.rules.rewrite.PushDownTopNThroughWindow;
 import org.apache.doris.nereids.rules.rewrite.PushFilterInsideJoin;
@@ -276,14 +272,14 @@ public class Rewriter extends AbstractBatchJobExecutor {
                     topDown(new BuildAggForUnion())
             ),
 
-            topic("Eager aggregation",
-                    topDown(
-                            new PushDownSumThroughJoin(),
-                            new PushDownMinMaxThroughJoin(),
-                            new PushDownCountThroughJoin()
-                    ),
-                    custom(RuleType.PUSH_DOWN_DISTINCT_THROUGH_JOIN, PushDownDistinctThroughJoin::new)
-            ),
+            // topic("Eager aggregation",
+            //         topDown(
+            //                 new PushDownSumThroughJoin(),
+            //                 new PushDownMinMaxThroughJoin(),
+            //                 new PushDownCountThroughJoin()
+            //         ),
+            //         custom(RuleType.PUSH_DOWN_DISTINCT_THROUGH_JOIN, PushDownDistinctThroughJoin::new)
+            // ),
 
             topic("Limit optimization",
                     // TODO: the logical plan should not contains any phase information,