From aca412260891c05a8019a8c546a9e4c93cec7ea7 Mon Sep 17 00:00:00 2001 From: jackwener Date: Thu, 23 Nov 2023 17:40:11 +0800 Subject: [PATCH] revert rules --- .../doris/nereids/jobs/executor/Rewriter.java | 20 ++++++++----------- 1 file changed, 8 insertions(+), 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 index ab79b19de11225..15e08d052e93f6 100644 --- 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,