cargo fmt failing

Author: fred1268

datafusion/functions-aggregate/benches/array_agg.rs

@@ -19,12 +19,15 @@ use std::hint::black_box;
 use std::sync::Arc;
 
 use arrow::array::{
-    Array, ArrayRef, ArrowPrimitiveType, AsArray, ListArray, NullBufferBuilder, StringArray,
+    Array, ArrayRef, ArrowPrimitiveType, AsArray, ListArray, NullBufferBuilder,
+    StringArray,
 };
 use arrow::datatypes::{DataType, Field, Int64Type};
 use criterion::{Criterion, criterion_group, criterion_main};
 use datafusion_expr::Accumulator;
-use datafusion_functions_aggregate::array_agg::{ArrayAggAccumulator, DistinctArrayAggAccumulator};
+use datafusion_functions_aggregate::array_agg::{
+    ArrayAggAccumulator, DistinctArrayAggAccumulator,
+};
 
 use arrow::buffer::OffsetBuffer;
 use arrow::util::bench_util::create_primitive_array;
@@ -278,8 +281,7 @@ fn distinct_array_agg_benchmark(c: &mut Criterion) {
     // --- High cardinality: ~5 % DB names, ~95 % near-unique random strings --
     // Worst-case scenario: almost every row is a new distinct value, so the
     // accumulator pays the full insertion cost for nearly every row.
-    let values =
-        Arc::new(create_string_array_high_cardinality(8192, 0.05)) as ArrayRef;
+    let values = Arc::new(create_string_array_high_cardinality(8192, 0.05)) as ArrayRef;
     distinct_update_batch_bench(
         c,
         "distinct_array_agg utf8 high cardinality (~7800 distinct, 5% db names)",

datafusion/functions-aggregate/src/array_agg.rs

@@ -28,10 +28,12 @@ use arrow::array::{
 };
 use arrow::buffer::{NullBuffer, OffsetBuffer, ScalarBuffer};
 use arrow::compute::{SortOptions, filter};
-use arrow::row::{Row, RowConverter, Rows, SortField};
 use arrow::datatypes::{DataType, Field, FieldRef, Fields};
+use arrow::row::{Row, RowConverter, Rows, SortField};
 
 use datafusion_common::cast::as_list_array;
+use datafusion_common::hash_utils::{RandomState, create_hashes};
+use datafusion_common::utils::proxy::HashTableAllocExt;
 use datafusion_common::utils::{
     SingleRowListArrayBuilder, compare_rows, get_row_at_idx, take_function_args,
 };
@@ -48,11 +50,9 @@ use datafusion_functions_aggregate_common::aggregate::groups_accumulator::nulls:
 use datafusion_functions_aggregate_common::merge_arrays::merge_ordered_arrays;
 use datafusion_functions_aggregate_common::order::AggregateOrderSensitivity;
 use datafusion_functions_aggregate_common::utils::ordering_fields;
-use datafusion_common::hash_utils::{RandomState, create_hashes};
-use datafusion_common::utils::proxy::HashTableAllocExt;
 use datafusion_macros::user_doc;
-use hashbrown::hash_table::HashTable;
 use datafusion_physical_expr_common::sort_expr::{LexOrdering, PhysicalSortExpr};
+use hashbrown::hash_table::HashTable;
 
 make_udaf_expr_and_func!(
     ArrayAgg,
@@ -1109,7 +1109,8 @@ impl Accumulator for DistinctArrayAggAccumulator {
             + self.map_size
             + self.counts.capacity() * size_of::<u64>()
             + self.hashes_buffer.capacity() * size_of::<u64>()
-            + self.datatype.size() - size_of_val(&self.datatype)
+            + self.datatype.size()
+            - size_of_val(&self.datatype)
     }
 }
 
@@ -2736,8 +2737,7 @@ mod tests {
             "postgres", "mysql", "postgres", "redis", "mysql", "duckdb", "redis",
         ]));
 
-        let mut acc =
-            DistinctArrayAggAccumulator::try_new(&DataType::Utf8, None, false)?;
+        let mut acc = DistinctArrayAggAccumulator::try_new(&DataType::Utf8, None, false)?;
         acc.update_batch(&[input])?;
 
         let result = acc.evaluate()?;
@@ -2826,8 +2826,9 @@ mod tests {
         use arrow::array::Date32Array;
 
         // 7 rows with 4 distinct dates (days since epoch), each duplicate appearing twice.
-        let input: ArrayRef =
-            Arc::new(Date32Array::from(vec![100i32, 200, 100, 300, 200, 400, 300]));
+        let input: ArrayRef = Arc::new(Date32Array::from(vec![
+            100i32, 200, 100, 300, 200, 400, 300,
+        ]));
 
         let mut acc =
             DistinctArrayAggAccumulator::try_new(&DataType::Date32, None, false)?;