Skip to content

Commit 0ba5f42

Browse files
committed
Update Optimizer.scala
1 parent f8b9314 commit 0ba5f42

File tree

1 file changed

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

1 file changed

+4
-3
lines changed

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,20 +36,21 @@ 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("Operator Optimizations", FixedPoint(100),
39+
Batch("Operator Reordering", FixedPoint(100),
4040
UnionPushdown,
4141
CombineFilters,
4242
PushPredicateThroughProject,
43+
PushPredicateThroughJoin,
4344
PushPredicateThroughGenerate,
4445
ColumnPruning,
4546
ProjectCollapsing,
46-
CombineLimits,
47+
CombineLimits) ::
48+
Batch("ConstantFolding", FixedPoint(100),
4749
NullPropagation,
4850
OptimizeIn,
4951
ConstantFolding,
5052
LikeSimplification,
5153
BooleanSimplification,
52-
PushPredicateThroughJoin,
5354
SimplifyFilters,
5455
SimplifyCasts,
5556
SimplifyCaseConversionExpressions) ::

0 commit comments

Comments
 (0)