Skip to content

BroadcastQueryStageExec Physical Operator

BroadcastQueryStageExec is a QueryStageExec.

Creating Instance

BroadcastQueryStageExec takes the following to be created:

BroadcastQueryStageExec is created when:

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.


Last update: 2020-08-12