Skip to content

Commit

Permalink
[opt](nereids) support pushdown agg distinct through join
Browse files Browse the repository at this point in the history
  • Loading branch information
xzj7019 committed Dec 4, 2024
1 parent ea8bcc7 commit c85ccfa
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -144,7 +144,8 @@ private static LogicalAggregate<Plan> pushDownAggWithDistinct(LogicalAggregate<?
rightAggOutputBuilder.build(), join.right());
}

Preconditions.checkState(leftJoin != join.left() || rightJoin != join.right());
Preconditions.checkState(leftJoin != join.left() || rightJoin != join.right(),
"not pushing down aggr with distinct through join on single side successfully");
Plan newJoin = join.withChildren(leftJoin, rightJoin);
LogicalAggregate<? extends Plan> newAggOverJoin = agg.withChildGroupByAndOutput(
ImmutableList.copyOf(newAggOverJoinGroupByKeys), projects, newJoin);
Expand Down

0 comments on commit c85ccfa

Please sign in to comment.