peter-toth commented on a change in pull request #32298:
URL: https://github.com/apache/spark/pull/32298#discussion_r644018925
##########
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/subquery.scala
##########
@@ -267,6 +268,33 @@ object ScalarSubquery {
}
}
+/**
+ * A subquery that is capable to return multiple scalar values.
+ */
+case class MultiScalarSubquery(
+ plan: LogicalPlan,
+ exprId: ExprId = NamedExpression.newExprId)
+ extends SubqueryExpression(plan, Seq.empty, exprId) with
LeafLike[Expression] with Unevaluable {
+ override def dataType: DataType = {
+ assert(plan.schema.nonEmpty, "Multi-column scalar subquery should have
columns")
Review comment:
This is not relevant in latest PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
