count group benchmark check

Author: coderfender

datafusion/functions-aggregate-common/src/aggregate/count_distinct/groups.rs

@@ -47,7 +47,6 @@ where
             num_groups: 0,
         }
     }
-
 }
 
 impl<T: ArrowPrimitiveType> Default for PrimitiveDistinctCountGroupsAccumulator<T>

datafusion/functions-aggregate/benches/count_distinct.rs

@@ -198,8 +198,13 @@ fn count_distinct_groups_benchmark(c: &mut Criterion) {
                     b.iter(|| {
                         let (_schema, args) = prepare_args(DataType::Int64);
                         let mut acc = count_fn.create_groups_accumulator(args).unwrap();
-                        acc.update_batch(&[values.clone()], &group_indices, None, num_groups)
-                            .unwrap();
+                        acc.update_batch(
+                            &[values.clone()],
+                            &group_indices,
+                            None,
+                            num_groups,
+                        )
+                        .unwrap();
                         acc.evaluate(EmitTo::All).unwrap()
                     })
                 },
@@ -216,7 +221,9 @@ fn count_distinct_groups_benchmark(c: &mut Criterion) {
                         let arr = values.as_any().downcast_ref::<Int64Array>().unwrap();
                         for (idx, group_idx) in group_indices.iter().enumerate() {
                             if let Some(val) = arr.value(idx).into() {
-                                let single_val = Arc::new(Int64Array::from(vec![Some(val)])) as ArrayRef;
+                                let single_val =
+                                    Arc::new(Int64Array::from(vec![Some(val)]))
+                                        as ArrayRef;
                                 accumulators[*group_idx]
                                     .update_batch(std::slice::from_ref(&single_val))
                                     .unwrap();
@@ -234,5 +241,9 @@ fn count_distinct_groups_benchmark(c: &mut Criterion) {
     }
 }
 
-criterion_group!(benches, count_distinct_benchmark, count_distinct_groups_benchmark);
+criterion_group!(
+    benches,
+    count_distinct_benchmark,
+    count_distinct_groups_benchmark
+);
 criterion_main!(benches);