|
Avoiding shuffle |
On the flow above, shuffled is needed to send records with the same key to the same partition/machine.
In the reference-join right-side data is broadcasted to all partitions, so that each partition can lookup a record that match to left site join. Thus no shuffle process is needed.
In the reference-lookup, right-side data is treated as distributedcache and loaded to all partitions, so that each partition can lookup a record in the distributedcashe that match to left site join. Thus no shuffle process is needed.