@@ -315,7 +315,7 @@ public class Rewriter extends AbstractBatchJobExecutor {
315
315
bottomUp (new MergeSetOperations (), new MergeSetOperationsExcept ()),
316
316
bottomUp (new PushProjectIntoOneRowRelation ()),
317
317
topDown (new MergeOneRowRelationIntoUnion ()),
318
- costBased ( topDown (new InferSetOperatorDistinct () )),
318
+ topDown (new InferSetOperatorDistinct ()),
319
319
topDown (new BuildAggForUnion ()),
320
320
bottomUp (new EliminateEmptyRelation ()),
321
321
// when union has empty relation child and constantExprsList is not empty,
@@ -355,12 +355,12 @@ public class Rewriter extends AbstractBatchJobExecutor {
355
355
),
356
356
357
357
topic ("Eager aggregation" ,
358
- costBased ( topDown (
358
+ topDown (
359
359
new PushDownAggWithDistinctThroughJoinOneSide (),
360
360
new PushDownAggThroughJoinOneSide (),
361
361
new PushDownAggThroughJoin ()
362
- )) ,
363
- costBased ( custom (RuleType .PUSH_DOWN_DISTINCT_THROUGH_JOIN , PushDownDistinctThroughJoin ::new ) ),
362
+ ),
363
+ custom (RuleType .PUSH_DOWN_DISTINCT_THROUGH_JOIN , PushDownDistinctThroughJoin ::new ),
364
364
topDown (new PushCountIntoUnionAll ())
365
365
),
366
366
0 commit comments