style: apply cargo fmt

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: GordonYuanyc

asap-query-engine/src/precompute_operators/count_min_sketch_accumulator.rs

@@ -3,8 +3,8 @@ use crate::data_model::{
     MultipleSubpopulationAggregate, SerializableToSink,
 };
 use crate::precompute_operators::sketchlib_runtime::{
-    RuntimeCountMin, cms_estimate, cms_from_matrix, cms_from_msgpack, cms_matrix,
-    cms_merge_refs, cms_new, cms_to_msgpack, cms_update,
+    cms_estimate, cms_from_matrix, cms_from_msgpack, cms_matrix, cms_merge_refs, cms_new,
+    cms_to_msgpack, cms_update, RuntimeCountMin,
 };
 use serde_json::Value;
 use std::collections::HashMap;
@@ -241,8 +241,7 @@ impl MergeableAccumulator<CountMinSketchAccumulator> for CountMinSketchAccumulat
         if accumulators.is_empty() {
             return Err("No accumulators to merge".into());
         }
-        let inner_refs: Vec<&RuntimeCountMin> =
-            accumulators.iter().map(|acc| &acc.inner).collect();
+        let inner_refs: Vec<&RuntimeCountMin> = accumulators.iter().map(|acc| &acc.inner).collect();
         let merged_inner = cms_merge_refs(&inner_refs)?;
         Ok(Self {
             inner: merged_inner,
@@ -292,18 +291,10 @@ mod tests {
     #[test]
     fn test_count_min_sketch_merge() {
         let cms1 = CountMinSketchAccumulator {
-            inner: cms_from_matrix(
-                vec![vec![5.0, 0.0, 0.0], vec![0.0, 0.0, 10.0]],
-                2,
-                3,
-            ),
+            inner: cms_from_matrix(vec![vec![5.0, 0.0, 0.0], vec![0.0, 0.0, 10.0]], 2, 3),
         };
         let cms2 = CountMinSketchAccumulator {
-            inner: cms_from_matrix(
-                vec![vec![3.0, 7.0, 0.0], vec![0.0, 0.0, 0.0]],
-                2,
-                3,
-            ),
+            inner: cms_from_matrix(vec![vec![3.0, 7.0, 0.0], vec![0.0, 0.0, 0.0]], 2, 3),
         };
 
         let merged = CountMinSketchAccumulator::merge_accumulators(vec![cms1, cms2]).unwrap();
@@ -325,11 +316,7 @@ mod tests {
     #[test]
     fn test_count_min_sketch_serialization() {
         let cms = CountMinSketchAccumulator {
-            inner: cms_from_matrix(
-                vec![vec![0.0, 42.0, 0.0], vec![0.0, 0.0, 100.0]],
-                2,
-                3,
-            ),
+            inner: cms_from_matrix(vec![vec![0.0, 42.0, 0.0], vec![0.0, 0.0, 100.0]], 2, 3),
         };
 
         let bytes = cms.serialize_to_bytes();
@@ -402,25 +389,13 @@ mod tests {
     #[test]
     fn test_count_min_sketch_merge_multiple() {
         let cms1 = CountMinSketchAccumulator {
-            inner: cms_from_matrix(
-                vec![vec![5.0, 0.0, 0.0], vec![0.0, 0.0, 10.0]],
-                2,
-                3,
-            ),
+            inner: cms_from_matrix(vec![vec![5.0, 0.0, 0.0], vec![0.0, 0.0, 10.0]], 2, 3),
         };
         let cms2 = CountMinSketchAccumulator {
-            inner: cms_from_matrix(
-                vec![vec![3.0, 7.0, 0.0], vec![0.0, 0.0, 0.0]],
-                2,
-                3,
-            ),
+            inner: cms_from_matrix(vec![vec![3.0, 7.0, 0.0], vec![0.0, 0.0, 0.0]], 2, 3),
         };
         let cms3 = CountMinSketchAccumulator {
-            inner: cms_from_matrix(
-                vec![vec![2.0, 0.0, 0.0], vec![0.0, 0.0, 5.0]],
-                2,
-                3,
-            ),
+            inner: cms_from_matrix(vec![vec![2.0, 0.0, 0.0], vec![0.0, 0.0, 5.0]], 2, 3),
         };
 
         let boxed_accs: Vec<Box<dyn AggregateCore>> =

asap-query-engine/src/precompute_operators/datasketches_kll_accumulator.rs

@@ -3,10 +3,10 @@ use crate::data_model::{
     SingleSubpopulationAggregate,
 };
 use crate::precompute_operators::sketchlib_runtime::{
-    RuntimeKll, kll_from_msgpack, kll_merge_refs, kll_new, kll_quantile, kll_sketch_bytes,
-    kll_to_msgpack, kll_update,
+    kll_from_msgpack, kll_merge_refs, kll_new, kll_quantile, kll_sketch_bytes, kll_to_msgpack,
+    kll_update, RuntimeKll,
 };
-use base64::{Engine as _, engine::general_purpose};
+use base64::{engine::general_purpose, Engine as _};
 use serde_json::Value;
 use std::collections::HashMap;
 #[cfg(feature = "extra_debugging")]
@@ -24,9 +24,7 @@ pub struct DatasketchesKLLAccumulator {
 
 impl DatasketchesKLLAccumulator {
     pub fn new(k: u16) -> Self {
-        Self {
-            inner: kll_new(k),
-        }
+        Self { inner: kll_new(k) }
     }
 
     pub fn update(&mut self, value: f64) {

asap-query-engine/src/precompute_operators/delta_set_aggregator_accumulator.rs

@@ -2,8 +2,8 @@ use crate::data_model::{
     AggregateCore, AggregationType, KeyByLabelValues, MergeableAccumulator,
     MultipleSubpopulationAggregate, SerializableToSink,
 };
-use asap_sketchlib::DeltaResult;
 use asap_sketchlib::message_pack_format::MessagePackCodec;
+use asap_sketchlib::DeltaResult;
 use serde_json::Value;
 use std::collections::{HashMap, HashSet};
 

asap-query-engine/src/precompute_operators/hydra_kll_accumulator.rs

@@ -5,8 +5,8 @@ use crate::{
     },
     KeyByLabelValues,
 };
-use asap_sketchlib::HydraKllSketch;
 use asap_sketchlib::message_pack_format::MessagePackCodec;
+use asap_sketchlib::HydraKllSketch;
 use base64::{engine::general_purpose, Engine as _};
 use std::collections::HashMap;
 

asap-query-engine/src/precompute_operators/set_aggregator_accumulator.rs

@@ -2,8 +2,8 @@ use crate::data_model::{
     AggregateCore, AggregationType, KeyByLabelValues, MergeableAccumulator,
     MultipleSubpopulationAggregate, SerializableToSink,
 };
-use asap_sketchlib::SetAggregator;
 use asap_sketchlib::message_pack_format::MessagePackCodec;
+use asap_sketchlib::SetAggregator;
 use serde_json::Value;
 use std::collections::{HashMap, HashSet};
 

asap-query-engine/src/precompute_operators/sketchlib_runtime.rs

@@ -166,11 +166,7 @@ pub fn kll_merge_refs(
     let k = first.k();
     for s in sketches {
         if s.k() != k {
-            return Err(format!(
-                "KLL k mismatch in merge: expected {k}, got {}",
-                s.k()
-            )
-            .into());
+            return Err(format!("KLL k mismatch in merge: expected {k}, got {}", s.k()).into());
         }
     }
     let mut merged = kll_new(k as u16);

asap-query-engine/tests/e2e_precompute_equivalence.rs

@@ -265,7 +265,8 @@ async fn e2e_kll_output_matches_arroyo() {
 
     // Sketch contents
     assert_eq!(
-        handcrafted_acc.inner.k(), arroyo_acc.inner.k(),
+        handcrafted_acc.inner.k(),
+        arroyo_acc.inner.k(),
         "KLL k mismatch"
     );
     assert_eq!(