BroadcastDistribution is a data distribution requirement of the children of BroadcastHashJoinExec and BroadcastNestedLoopJoinExec physical operators.
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 is always
requiredNumPartitions is part of the Distribution abstraction.
createPartitioning( numPartitions: Int): Partitioning
createPartitioning creates a BroadcastPartitioning (with the BroadcastMode).
createPartitioning throws an
AssertionError when the given
numPartitions is not
The default partitioning of BroadcastDistribution can only have 1 partition.
createPartitioning is part of the Distribution abstraction.