ExecSubqueryExpression

ExecSubqueryExpression Contract — Catalyst Expressions with SubqueryExec Physical Operators

ExecSubqueryExpression is the contract for Catalyst expressions that contain a physical plan with SubqueryExec physical operator (i.e. PlanExpression[SubqueryExec]).

package org.apache.spark.sql.execution

abstract class ExecSubqueryExpression extends PlanExpression[SubqueryExec] {
  def updateResult(): Unit
}

Table 1. ExecSubqueryExpression Contract
Method	Description
`updateResult`	Used exclusively when a physical operator is requested to waitForSubqueries (when executed as part of Physical Operator Execution Pipeline).

Table 2. ExecSubqueryExpressions
ExecSubqueryExpression	Description
InSubquery
ScalarSubquery

ExecSubqueryExpression Contract — Catalyst Expressions with SubqueryExec Physical Operators