This is an automated email from the ASF dual-hosted git repository.

yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git

commit d9943d037487c77d0cb3212be55612fa86a7f372
Author: chen <czjour...@163.com>
AuthorDate: Tue Mar 5 16:19:09 2024 +0800

    [chore](Nereids) change consumer rules name (#31777)
---
 .../src/main/java/org/apache/doris/nereids/rules/RuleType.java      | 6 +++---
 .../doris/nereids/rules/rewrite/CollectFilterAboveConsumer.java     | 2 +-
 .../doris/nereids/rules/rewrite/CollectProjectAboveConsumer.java    | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/RuleType.java 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/RuleType.java
index 3b56738230e..c42f0ef008b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/RuleType.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/RuleType.java
@@ -288,14 +288,14 @@ public enum RuleType {
     PULL_UP_CTE_ANCHOR(RuleTypeClass.REWRITE),
     CTE_INLINE(RuleTypeClass.REWRITE),
     REWRITE_CTE_CHILDREN(RuleTypeClass.REWRITE),
-    COLLECT_FILTER_ON_CONSUMER(RuleTypeClass.REWRITE),
+    COLLECT_FILTER_ABOVE_CTE_CONSUMER(RuleTypeClass.REWRITE),
     INLINE_VIEW(RuleTypeClass.REWRITE),
     CHECK_PRIVILEGES(RuleTypeClass.REWRITE),
 
     COLLECT_FILTER(RuleTypeClass.REWRITE),
     COLLECT_JOIN_CONSTRAINT(RuleTypeClass.REWRITE),
-    COLLECT_PROJECT_ABOVE_CONSUMER(RuleTypeClass.REWRITE),
-    COLLECT_PROJECT_ABOVE_FILTER_CONSUMER(RuleTypeClass.REWRITE),
+    COLLECT_PROJECT_ABOVE_CTE_CONSUMER(RuleTypeClass.REWRITE),
+    COLLECT_PROJECT_ABOVE_FILTER_CTE_CONSUMER(RuleTypeClass.REWRITE),
 
     LEADING_JOIN(RuleTypeClass.REWRITE),
     REWRITE_SENTINEL(RuleTypeClass.REWRITE),
diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectFilterAboveConsumer.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectFilterAboveConsumer.java
index 4c4249b69c7..d2e61f9e665 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectFilterAboveConsumer.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectFilterAboveConsumer.java
@@ -47,6 +47,6 @@ public class CollectFilterAboveConsumer extends 
OneRewriteRuleFactory {
                 
ctx.cascadesContext.putConsumerIdToFilter(cteConsumer.getRelationId(), 
rewrittenExpr);
             }
             return ctx.root;
-        }).toRule(RuleType.COLLECT_FILTER_ON_CONSUMER);
+        }).toRule(RuleType.COLLECT_FILTER_ABOVE_CTE_CONSUMER);
     }
 }
diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectProjectAboveConsumer.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectProjectAboveConsumer.java
index 43f8231cbc3..0ecace726db 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectProjectAboveConsumer.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectProjectAboveConsumer.java
@@ -40,7 +40,7 @@ public class CollectProjectAboveConsumer implements 
RewriteRuleFactory {
 
     @Override
     public List<Rule> buildRules() {
-        return ImmutableList.of(RuleType.COLLECT_PROJECT_ABOVE_CONSUMER
+        return ImmutableList.of(RuleType.COLLECT_PROJECT_ABOVE_CTE_CONSUMER
                         
.build(logicalProject(logicalCTEConsumer()).thenApply(ctx -> {
                             LogicalProject<LogicalCTEConsumer> project = 
ctx.root;
                             List<NamedExpression> namedExpressions = 
project.getProjects();
@@ -48,7 +48,7 @@ public class CollectProjectAboveConsumer implements 
RewriteRuleFactory {
                             collectProject(ctx.cascadesContext, 
namedExpressions, cteConsumer);
                             return ctx.root;
                         })),
-                RuleType.COLLECT_PROJECT_ABOVE_FILTER_CONSUMER
+                RuleType.COLLECT_PROJECT_ABOVE_FILTER_CTE_CONSUMER
                         
.build(logicalProject(logicalFilter(logicalCTEConsumer())).thenApply(ctx -> {
                             LogicalProject<LogicalFilter<LogicalCTEConsumer>> 
project = ctx.root;
                             LogicalFilter<LogicalCTEConsumer> filter = 
project.child();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to