datafusion_physical_optimizer::enforce_distribution

Function reorder_partitioned_join_keys

Source 
pub fn reorder_partitioned_join_keys<F>(
    join_plan: PlanWithKeyRequirements,
    on: &[(PhysicalExprRef, PhysicalExprRef)],
    sort_options: &[SortOptions],
    join_constructor: &F,
) -> Result<PlanWithKeyRequirements>
where
    F: Fn((Vec<(PhysicalExprRef, PhysicalExprRef)>, Vec<SortOptions>)) -> Result<Arc<dyn ExecutionPlan>>,