partitioned_hash_join

Function partitioned_hash_join 

Source
pub(crate) fn partitioned_hash_join(
    hash_join: &HashJoinExec,
) -> Result<Arc<dyn ExecutionPlan>>
Expand description

Creates a partitioned hash join execution plan, swapping inputs if beneficial.

Checks if the join order should be swapped based on the join type and input statistics. If swapping is optimal and supported, creates a swapped partitioned hash join; otherwise, creates a standard partitioned hash join.