We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e50d307 commit f889c91Copy full SHA for f889c91
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -774,8 +774,7 @@ object CombineFilters extends Rule[LogicalPlan] {
774
*/
775
object PruneFilters extends Rule[LogicalPlan] with PredicateHelper {
776
def apply(plan: LogicalPlan): LogicalPlan = plan transform {
777
- case f @ Filter(fc, p: LogicalPlan)
778
- if splitConjunctivePredicates(fc).filter(_.deterministic).exists(p.constraints.contains) =>
+ case f @ Filter(fc, p: LogicalPlan) =>
779
val (prunedPredicates, remainingPredicates) =
780
splitConjunctivePredicates(fc).partition { cond =>
781
cond.deterministic && p.constraints.contains(cond)
0 commit comments