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