Skip to content

Commit e2a491d

Browse files
committed
Update Optimizer.scala
1 parent f03fe7f commit e2a491d

File tree

1 file changed

+7
-7
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer

1 file changed

+7
-7
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,13 @@ object DefaultOptimizer extends Optimizer {
3636
// SubQueries are only needed for analysis and can be removed before execution.
3737
Batch("Remove SubQueries", FixedPoint(100),
3838
EliminateSubQueries) ::
39+
Batch("Filter Pushdown", FixedPoint(100),
40+
UnionPushdown,
41+
CombineFilters,
42+
PushPredicateThroughProject,
43+
PushPredicateThroughJoin,
44+
PushPredicateThroughGenerate,
45+
ColumnPruning) ::
3946
Batch("Combine Limits", FixedPoint(100),
4047
CombineLimits) ::
4148
Batch("ConstantFolding", FixedPoint(100),
@@ -49,13 +56,6 @@ object DefaultOptimizer extends Optimizer {
4956
OptimizeIn) ::
5057
Batch("Decimal Optimizations", FixedPoint(100),
5158
DecimalAggregates) ::
52-
Batch("Filter Pushdown", FixedPoint(100),
53-
UnionPushdown,
54-
CombineFilters,
55-
PushPredicateThroughProject,
56-
PushPredicateThroughJoin,
57-
PushPredicateThroughGenerate,
58-
ColumnPruning) ::
5959
Batch("LocalRelation", FixedPoint(100),
6060
ConvertToLocalRelation) :: Nil
6161
}

0 commit comments

Comments
 (0)