Update Optimizer.scala

rekhajoshm · Jun 10, 2015 · 0ba5f42 · 0ba5f42
1 parent f8b9314
commit 0ba5f42
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -36,20 +36,21 @@ object DefaultOptimizer extends Optimizer {
     // SubQueries are only needed for analysis and can be removed before execution.
     Batch("Remove SubQueries", FixedPoint(100),
       EliminateSubQueries) ::
-    Batch("Operator Optimizations", FixedPoint(100),
+    Batch("Operator Reordering", FixedPoint(100),
       UnionPushdown,
       CombineFilters,
       PushPredicateThroughProject,
+      PushPredicateThroughJoin,
       PushPredicateThroughGenerate,
       ColumnPruning,
       ProjectCollapsing,
-      CombineLimits,
+      CombineLimits) ::
+    Batch("ConstantFolding", FixedPoint(100),
       NullPropagation,
       OptimizeIn,
       ConstantFolding,
       LikeSimplification,
       BooleanSimplification,
-      PushPredicateThroughJoin,
       SimplifyFilters,
       SimplifyCasts,
       SimplifyCaseConversionExpressions) ::