database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[chore](Nereids) change consumer rules name (#31777)

Browse Source
This commit is contained in:
chen
2024-03-05 16:19:09 +08:00
committed by yiguolei
parent ad3308c8ab
commit d9943d0374
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/RuleType.java
View File

@ -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),

2
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectFilterAboveConsumer.java
View File

@ -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);
}
}

4
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/CollectProjectAboveConsumer.java
View File

@ -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();