add exists to tree node

prabeesh · Jul 21, 2015 · 330021e · 330021e
1 parent 2cab68c
commit 330021e
Showing 1 changed file with 3 additions and 5 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
@@ -546,11 +546,9 @@ object PushPredicateThroughProject extends Rule[LogicalPlan] with PredicateHelpe
   private def hasNondeterministic(
       condition: Expression,
       sourceAliases: AttributeMap[Expression]) = {
-    condition.find {
-      case a: Attribute =>
-        sourceAliases.get(a).map(_.find(!_.deterministic).isDefined).getOrElse(false)
-      case _ => false
-    }.isDefined
+    condition.collect {
+      case a: Attribute if sourceAliases.contains(a) => sourceAliases(a)
+    }.exists(!_.deterministic)
   }
 
   // Substitute any attributes that are produced by the child projection, so that we safely