From ce3cdcdbc034ebc69b2270e00fb1df2b26386e15 Mon Sep 17 00:00:00 2001 From: Matthew Gapp <61894094+matthewgapp@users.noreply.github.com> Date: Sat, 18 Nov 2023 14:09:14 -0800 Subject: [PATCH] wip: remove dead code --- .../enforce_distribution.rs | 24 ------------------- 1 file changed, 24 deletions(-) diff --git a/datafusion/core/src/physical_optimizer/enforce_distribution.rs b/datafusion/core/src/physical_optimizer/enforce_distribution.rs index d6374eec1e2d..114e1176bc24 100644 --- a/datafusion/core/src/physical_optimizer/enforce_distribution.rs +++ b/datafusion/core/src/physical_optimizer/enforce_distribution.rs @@ -1114,30 +1114,6 @@ fn remove_dist_changing_operators( }) } -// /// Changes each child of the `dist_context.plan` such that they no longer -// /// use order preserving variants, if no ordering is required at the output -// /// of the physical plan (there is no global ordering requirement by the query). -// fn update_plan_to_remove_unnecessary_final_order( -// dist_context: DistributionContext, -// ) -> Result> { -// let DistributionContext { -// plan, -// distribution_onwards, -// .. -// } = dist_context; -// let new_children = izip!(plan.children(), distribution_onwards) -// .map(|(mut child, mut dist_onward)| { -// replace_order_preserving_variants(&mut child, &mut dist_onward)?; -// Ok(child) -// }) -// .collect::>>()?; -// if !new_children.is_empty() { -// plan.with_new_children(new_children) -// } else { -// Ok(plan) -// } -// } - /// Updates the physical plan `input` by using `dist_onward` replace order preserving operator variants /// with their corresponding operators that do not preserve order. It is a wrapper for `replace_order_preserving_variants_helper` fn replace_order_preserving_variants(