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

[Bug](materialized-view) fix not match mv when some alias on agg (#25321)

Browse Source 
fix not match mv when some alias on agg
This commit is contained in:
Pxl
2023-10-12 11:02:55 +08:00
committed by GitHub
parent f14e4311c4
commit a0d2b1ec56
4 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/mv/AbstractSelectMaterializedIndexRule.java
View File

@ -605,16 +605,20 @@ public abstract class AbstractSelectMaterializedIndexRule {
}
}
protected List<NamedExpression> generateProjectsAlias(
List<? extends NamedExpression> oldProjects, SlotContext slotContext) {
protected List<NamedExpression> generateProjectsAlias(List<? extends NamedExpression> oldProjects,
SlotContext slotContext) {
return oldProjects.stream().map(e -> {
Expression real = e;
if (real instanceof Alias) {
real = real.child(0);
}
if (slotContext.baseSlotToMvSlot.containsKey(e.toSlot())) {
return new Alias(e.getExprId(), slotContext.baseSlotToMvSlot.get(e.toSlot()), e.getName());
}
if (slotContext.mvNameToMvSlot.containsKey(e.toSql())) {
return new Alias(e.getExprId(), slotContext.mvNameToMvSlot.get(e.toSql()), e.getName());
if (slotContext.mvNameToMvSlot.containsKey(real.toSql())) {
return new Alias(e.getExprId(), slotContext.mvNameToMvSlot.get(real.toSql()), e.getName());
}
return e;
return e.toSlot();
}).collect(ImmutableList.toImmutableList());
}
}

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

@ -213,7 +213,7 @@ public class SelectMaterializedIndexWithAggregate extends AbstractSelectMaterial
if (result.exprRewriteMap.isEmpty()) {
return new LogicalProject<>(
generateProjectsAlias(agg.getOutput(), slotContext),
generateProjectsAlias(agg.getOutputs(), slotContext),
new ReplaceExpressions(slotContext).replace(
agg.withChildren(
project.withProjectsAndChild(