18
18
use std:: sync:: Arc ;
19
19
20
20
use crate :: physical_optimizer:: test_utils:: {
21
- check_integrity, stream_exec_ordered_with_projection,
21
+ check_integrity, sort_preserving_merge_exec , stream_exec_ordered_with_projection,
22
22
} ;
23
23
24
24
use datafusion:: prelude:: SessionContext ;
@@ -35,7 +35,6 @@ use datafusion_physical_plan::joins::{HashJoinExec, PartitionMode};
35
35
use datafusion_physical_plan:: memory:: MemorySourceConfig ;
36
36
use datafusion_physical_plan:: repartition:: RepartitionExec ;
37
37
use datafusion_physical_plan:: sorts:: sort:: SortExec ;
38
- use datafusion_physical_plan:: sorts:: sort_preserving_merge:: SortPreservingMergeExec ;
39
38
use datafusion_physical_plan:: {
40
39
displayable, get_plan_string, ExecutionPlan , Partitioning ,
41
40
} ;
@@ -1158,14 +1157,6 @@ fn sort_exec(
1158
1157
)
1159
1158
}
1160
1159
1161
- fn sort_preserving_merge_exec (
1162
- sort_exprs : impl IntoIterator < Item = PhysicalSortExpr > ,
1163
- input : Arc < dyn ExecutionPlan > ,
1164
- ) -> Arc < dyn ExecutionPlan > {
1165
- let sort_exprs = sort_exprs. into_iter ( ) . collect ( ) ;
1166
- Arc :: new ( SortPreservingMergeExec :: new ( sort_exprs, input) )
1167
- }
1168
-
1169
1160
fn repartition_exec_round_robin ( input : Arc < dyn ExecutionPlan > ) -> Arc < dyn ExecutionPlan > {
1170
1161
Arc :: new ( RepartitionExec :: try_new ( input, Partitioning :: RoundRobinBatch ( 8 ) ) . unwrap ( ) )
1171
1162
}
0 commit comments