Skip to content

ShuffledJoin Physical Operators

ShuffledJoin is an extension of the BaseJoinExec abstraction for join operators that shuffle two child relations using the join keys.


Required Child Output Distribution

requiredChildDistribution: Seq[Distribution]

requiredChildDistribution is part of the SparkPlan abstraction.

requiredChildDistribution are HashClusteredDistributions for the left and right keys.

Output Data Partitioning Requirements

outputPartitioning: Partitioning

outputPartitioning is part of the SparkPlan abstraction.


Output Attributes

output: Seq[Attribute]

output is part of the QueryPlan abstraction.


Back to top