File tree Expand file tree Collapse file tree 2 files changed +2
-1
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer
core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 2 files changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -51,6 +51,7 @@ abstract class Optimizer(catalogManager: CatalogManager)
5151 override protected val excludedOnceBatches : Set [String ] =
5252 Set (
5353 " PartitionPruning" ,
54+ " Infer Filters from PartitionPruning" ,
5455 " Extract Python UDFs" )
5556
5657 protected def fixedPoint =
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ class SparkOptimizer(
4646 OptimizeSubqueries ) :+
4747 Batch (" Pushdown Filters from PartitionPruning" , fixedPoint,
4848 PushDownPredicates ) :+
49- Batch (" Infer Filters from DynamicPruning " , Once ,
49+ Batch (" Infer Filters from PartitionPruning " , Once ,
5050 InferFiltersFromConstraints ) :+
5151 Batch (" Cleanup filters that cannot be pushed down" , Once ,
5252 CleanupDynamicPruningFilters ,
You can’t perform that action at this time.
0 commit comments