Skip to content

Commit

Permalink
tmp
Browse files Browse the repository at this point in the history
  • Loading branch information
seawinde committed Dec 6, 2023
1 parent 321c0e5 commit cc8ab25
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -52,10 +52,11 @@ protected Plan rewriteQueryByView(MatchMode matchMode,

PlanSplitContext planSplitContext = new PlanSplitContext(Sets.newHashSet(LogicalAggregate.class));
viewStructInfo.getTopPlan().accept(StructInfo.PLAN_SPLITTER, planSplitContext);

// generate aggregate in mv and mv output expression mapping
LogicalAggregate<Plan> bottomAggregate = (LogicalAggregate<Plan>) planSplitContext.getBottomPlan().get(0);
Plan topPlan = planSplitContext.getTopPlan();
ExpressionMapping aggregateToTopExpressionMapping = generateAggregateToTopMapping(bottomAggregate, topPlan);

return null;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -239,7 +239,7 @@ public Void visit(Plan plan, Set<Expression> predicates) {

/**
* Split the plan into bottom and up, the boundary is given by context,
* the bottom contains the boundary.
* the bottom contains the boundary, and top plan doesn't contain the boundary.
*/
public static class PlanSplitter extends DefaultPlanVisitor<Void, PlanSplitContext> {
@Override
Expand Down

0 comments on commit cc8ab25

Please sign in to comment.