BroadcastQueryStageExec Physical Operator¶
BroadcastQueryStageExec is a QueryStageExec.
BroadcastQueryStageExec takes the following to be created:
BroadcastQueryStageExec is created when:
AdaptiveSparkPlanExecphysical operator is requested to newQueryStage (for a BroadcastExchangeExec)
BroadcastQueryStageExecphysical operator is requested to newReuseInstance
getRuntimeStatistics is part of the QueryStageExec abstraction.
getRuntimeStatistics requests the BroadcastExchangeLike operator for the runtime statistics.
BroadcastExchangeExec Physical Operator¶
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.