Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/23211#discussion_r240092936
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/subquery.scala
---
@@ -267,6 +267,17 @@ object ScalarSubquery {
case _ => false
}.isDefined
}
+
+ def hasScalarSubquery(e: Expression): Boolean = {
+ e.find {
+ case s: ScalarSubquery => true
+ case _ => false
+ }.isDefined
+ }
+
+ def hasScalarSubquery(e: Seq[Expression]): Boolean = {
+ e.find(hasScalarSubquery(_)).isDefined
--- End diff --
`e.exists(hasScalarSubquery)`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
