BroadcastDistribution¶

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

Creating Instance¶

BroadcastDistribution takes the following to be created:

• BroadcastMode

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¶

createPartitioning(
  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.