File tree 2 files changed +4
-11
lines changed
datafusion/physical-plan/src/aggregates/group_values
2 files changed +4
-11
lines changed Original file line number Diff line number Diff line change @@ -1077,9 +1077,7 @@ mod tests {
1077
1077
use datafusion_common:: utils:: proxy:: RawTableAllocExt ;
1078
1078
use datafusion_expr:: EmitTo ;
1079
1079
1080
- use crate :: aggregates:: group_values:: {
1081
- column:: GroupValuesColumn , GroupValues ,
1082
- } ;
1080
+ use crate :: aggregates:: group_values:: { column:: GroupValuesColumn , GroupValues } ;
1083
1081
1084
1082
use super :: GroupIndexView ;
1085
1083
@@ -1151,8 +1149,7 @@ mod tests {
1151
1149
1152
1150
let field = Field :: new ( "item" , DataType :: Int32 , true ) ;
1153
1151
let schema = Arc :: new ( Schema :: new_with_metadata ( vec ! [ field] , HashMap :: new ( ) ) ) ;
1154
- let mut group_values =
1155
- GroupValuesColumn :: < false > :: try_new ( schema) . unwrap ( ) ;
1152
+ let mut group_values = GroupValuesColumn :: < false > :: try_new ( schema) . unwrap ( ) ;
1156
1153
1157
1154
// Insert group index views and check if success to insert
1158
1155
insert_inline_group_index_view ( & mut group_values, 0 , 0 ) ;
Original file line number Diff line number Diff line change @@ -150,13 +150,9 @@ pub fn new_group_values(
150
150
151
151
if column:: supported_schema ( schema. as_ref ( ) ) {
152
152
if matches ! ( group_ordering, GroupOrdering :: None ) {
153
- Ok ( Box :: new ( GroupValuesColumn :: < false > :: try_new (
154
- schema,
155
- ) ?) )
153
+ Ok ( Box :: new ( GroupValuesColumn :: < false > :: try_new ( schema) ?) )
156
154
} else {
157
- Ok ( Box :: new ( GroupValuesColumn :: < true > :: try_new (
158
- schema,
159
- ) ?) )
155
+ Ok ( Box :: new ( GroupValuesColumn :: < true > :: try_new ( schema) ?) )
160
156
}
161
157
} else {
162
158
Ok ( Box :: new ( GroupValuesRows :: try_new ( schema) ?) )
You can’t perform that action at this time.
0 commit comments