BroadcastQueryStageExec Physical Operator¶

BroadcastQueryStageExec is a QueryStageExec.

Creating Instance¶

BroadcastQueryStageExec takes the following to be created:

• ID
• SparkPlan

BroadcastQueryStageExec is created when:

• AdaptiveSparkPlanExec physical operator is requested to newQueryStage (for a BroadcastExchangeExec)

• BroadcastQueryStageExec physical operator is requested to newReuseInstance

Runtime Statistics¶

getRuntimeStatistics: Statistics

getRuntimeStatistics is part of the QueryStageExec abstraction.

getRuntimeStatistics requests the BroadcastExchangeLike operator for the runtime statistics.

materializeWithTimeout¶

materializeWithTimeout: Future[Any]

materializeWithTimeout is...FIXME

BroadcastExchangeExec Physical Operator¶

broadcast: BroadcastExchangeExec

BroadcastQueryStageExec creates a BroadcastExchangeExec when created.

Creating BroadcastQueryStageExec Physical Operator¶

newReuseInstance(
  newStageId: Int,
  newOutput: Seq[Attribute]): QueryStageExec

newReuseInstance creates a new BroadcastQueryStageExec with the given newStageId and a new ReusedExchangeExec (with the given newOutput and the broadcast).

newReuseInstance is part of the QueryStageExec abstraction.