Skip to content

Commit 20de7be

Browse files
committed
Update Optimizer.scala
1 parent 7bc7d28 commit 20de7be

File tree

1 file changed

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

1 file changed

+3
-4
lines changed

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

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,21 +38,20 @@ object DefaultOptimizer extends Optimizer {
3838
EliminateSubQueries) ::
3939
Batch("Distinct", FixedPoint(100),
4040
ReplaceDistinctWithAggregate) ::
41-
Batch("Operator Reordering", FixedPoint(100),
41+
Batch("Operator Optimizations", FixedPoint(100),
4242
UnionPushdown,
4343
CombineFilters,
4444
PushPredicateThroughProject,
45-
PushPredicateThroughJoin,
4645
PushPredicateThroughGenerate,
4746
ColumnPruning,
4847
ProjectCollapsing,
49-
CombineLimits) ::
50-
Batch("ConstantFolding", FixedPoint(100),
48+
CombineLimits,
5149
NullPropagation,
5250
OptimizeIn,
5351
ConstantFolding,
5452
LikeSimplification,
5553
BooleanSimplification,
54+
PushPredicateThroughJoin,
5655
SimplifyFilters,
5756
SimplifyCasts,
5857
SimplifyCaseConversionExpressions) ::

0 commit comments

Comments
 (0)