Skip to content

Commit 274e535

Browse files
buraksennalambberkaysynnada
authored
Move EnforceSorting into datafusion-physical-optimizer crate (#14219)
* passes lint * forgotten license header * import order * fix tests * Revert datafusion-testing update * unify utils --------- Co-authored-by: Andrew Lamb <[email protected]> Co-authored-by: berkaysynnada <[email protected]>
1 parent 5edb276 commit 274e535

17 files changed

+4348
-4366
lines changed

datafusion-cli/Cargo.lock

+1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

datafusion/core/src/physical_optimizer/enforce_distribution.rs

+4-4
Original file line numberDiff line numberDiff line change
@@ -26,10 +26,6 @@ use std::sync::Arc;
2626

2727
use crate::config::ConfigOptions;
2828
use crate::error::Result;
29-
use crate::physical_optimizer::utils::{
30-
add_sort_above_with_check, is_coalesce_partitions, is_repartition,
31-
is_sort_preserving_merge,
32-
};
3329
use crate::physical_plan::aggregates::{AggregateExec, AggregateMode, PhysicalGroupBy};
3430
use crate::physical_plan::coalesce_partitions::CoalescePartitionsExec;
3531
use crate::physical_plan::joins::{
@@ -54,6 +50,10 @@ use datafusion_physical_expr::{
5450
};
5551
use datafusion_physical_expr_common::sort_expr::LexOrdering;
5652
use datafusion_physical_optimizer::output_requirements::OutputRequirementExec;
53+
use datafusion_physical_optimizer::utils::{
54+
add_sort_above_with_check, is_coalesce_partitions, is_repartition,
55+
is_sort_preserving_merge,
56+
};
5757
use datafusion_physical_optimizer::PhysicalOptimizerRule;
5858
use datafusion_physical_plan::execution_plan::EmissionType;
5959
use datafusion_physical_plan::windows::{get_best_fitting_window, BoundedWindowAggExec};

0 commit comments

Comments
 (0)