fmt

Author: Dandandan

datafusion/functions-aggregate-common/src/aggregate/groups_accumulator/accumulate.rs

@@ -110,7 +110,10 @@ impl NullState {
         T: ArrowPrimitiveType + Send,
         F: FnMut(usize, T::Native) + Send,
     {
-        if self.seen_values.capacity() == 0 && opt_filter.is_none() && values.null_count() == 0 {
+        if self.seen_values.capacity() == 0
+            && opt_filter.is_none()
+            && values.null_count() == 0
+        {
             accumulate(group_indices, values, None, value_fn);
             self.seen_values_size = total_num_groups;
         } else {
@@ -155,7 +158,10 @@ impl NullState {
         let data = values.values();
         assert_eq!(data.len(), group_indices.len());
 
-        if self.seen_values.capacity() == 0 && opt_filter.is_none() && values.null_count() == 0 {
+        if self.seen_values.capacity() == 0
+            && opt_filter.is_none()
+            && values.null_count() == 0
+        {
             group_indices
                 .iter()
                 .zip(data.iter())
@@ -164,7 +170,8 @@ impl NullState {
 
             return;
         }
-        let prev_seen: bool = self.seen_values.capacity() == 0 && self.seen_values_size > 0;
+        let prev_seen: bool =
+            self.seen_values.capacity() == 0 && self.seen_values_size > 0;
         // ensure the seen_values is big enough (start everything at
         // "not seen" valid)
         let seen_values =