@@ -32,9 +32,7 @@ mod tests {
32
32
use arrow:: datatypes:: { DataType , Field , Schema } ;
33
33
use datafusion_common:: ScalarValue ;
34
34
use datafusion_expr:: { AggregateUDF , AggregateUDFImpl , Signature , Volatility } ;
35
- use std:: any:: Any ;
36
- use std:: sync:: Arc ;
37
-
35
+ use std:: { any:: Any , sync:: Arc } ;
38
36
#[ derive( Debug ) ]
39
37
struct DummyUdf {
40
38
signature : Signature ,
@@ -120,26 +118,25 @@ pub mod utils {
120
118
DecimalAverager , Hashable ,
121
119
} ;
122
120
}
123
-
124
- use std:: borrow:: Cow ;
125
- use std:: fmt:: Debug ;
126
- use std:: sync:: Arc ;
127
-
128
121
use crate :: expressions:: Column ;
129
-
130
- use arrow:: compute:: SortOptions ;
131
- use arrow:: datatypes:: { DataType , FieldRef , Schema , SchemaRef } ;
122
+ use arrow:: {
123
+ compute:: SortOptions ,
124
+ datatypes:: { DataType , FieldRef , Schema , SchemaRef } ,
125
+ } ;
132
126
use datafusion_common:: { internal_err, not_impl_err, Result , ScalarValue } ;
133
127
use datafusion_expr:: { AggregateUDF , ReversedUDAF , SetMonotonicity } ;
134
- use datafusion_expr_common:: accumulator:: Accumulator ;
135
- use datafusion_expr_common:: groups_accumulator:: GroupsAccumulator ;
136
- use datafusion_expr_common:: type_coercion:: aggregates:: check_arg_count;
137
- use datafusion_functions_aggregate_common:: accumulator:: {
138
- AccumulatorArgs , StateFieldsArgs ,
128
+ use datafusion_expr_common:: {
129
+ accumulator:: Accumulator , groups_accumulator:: GroupsAccumulator ,
130
+ type_coercion:: aggregates:: check_arg_count,
131
+ } ;
132
+ use datafusion_functions_aggregate_common:: {
133
+ accumulator:: { AccumulatorArgs , StateFieldsArgs } ,
134
+ order:: AggregateOrderSensitivity ,
135
+ } ;
136
+ use datafusion_physical_expr_common:: {
137
+ physical_expr:: PhysicalExpr , sort_expr:: PhysicalSortExpr ,
139
138
} ;
140
- use datafusion_functions_aggregate_common:: order:: AggregateOrderSensitivity ;
141
- use datafusion_physical_expr_common:: physical_expr:: PhysicalExpr ;
142
- use datafusion_physical_expr_common:: sort_expr:: PhysicalSortExpr ;
139
+ use std:: { borrow:: Cow , fmt:: Debug , sync:: Arc } ;
143
140
144
141
/// Builder for physical [`AggregateFunctionExpr`]
145
142
///
0 commit comments