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

results matching ""

    No results matching ""