Skip to content


BroadcastDistribution is a data distribution requirement of the children of BroadcastHashJoinExec and BroadcastNestedLoopJoinExec physical operators.

Creating Instance

BroadcastDistribution takes the following to be created:

BroadcastDistribution is created when BroadcastHashJoinExec and BroadcastNestedLoopJoinExec physical operators are requested for the required child distribution.

Required Number of Partitions

requiredNumPartitions: Option[Int]

requiredNumPartitions is always 1.

requiredNumPartitions is part of the Distribution abstraction.

Creating Partitioning

  numPartitions: Int): Partitioning

createPartitioning creates a BroadcastPartitioning (with the BroadcastMode).

createPartitioning throws an AssertionError when the given numPartitions is not 1:

The default partitioning of BroadcastDistribution can only have 1 partition.

createPartitioning is part of the Distribution abstraction.