Skip to content

Commit 22e7886

Browse files
committed
Move rule before
1 parent f524af7 commit 22e7886

File tree

1 file changed

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

1 file changed

+2
-10
lines changed

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

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,8 @@ abstract class Optimizer(catalogManager: CatalogManager)
176176
// to enforce idempotence on it and we change this batch from Once to FixedPoint(1).
177177
Batch("Subquery", FixedPoint(1),
178178
OptimizeSubqueries) ::
179+
Batch("RewriteSubquery", Once,
180+
RewritePredicateSubquery) ::
179181
Batch("Replace Operators", fixedPoint,
180182
RewriteExceptAll,
181183
RewriteIntersectAll,
@@ -224,16 +226,6 @@ abstract class Optimizer(catalogManager: CatalogManager)
224226
// The following batch should be executed after batch "Join Reorder" and "LocalRelation".
225227
Batch("Check Cartesian Products", Once,
226228
CheckCartesianProducts) :+
227-
Batch("RewriteSubquery", Once,
228-
RewritePredicateSubquery,
229-
PushPredicateThroughJoin,
230-
LimitPushDown,
231-
ColumnPruning,
232-
CollapseProject,
233-
RemoveRedundantAliases,
234-
RemoveNoopOperators,
235-
InferFiltersFromConstraints,
236-
PushDownPredicates) :+
237229
// This batch must be executed after the `RewriteSubquery` batch, which creates joins.
238230
Batch("NormalizeFloatingNumbers", Once, NormalizeFloatingNumbers) :+
239231
Batch("ReplaceUpdateFieldsExpression", Once, ReplaceUpdateFieldsExpression)

0 commit comments

Comments
 (0)