fix fmt

huaxingao · Apr 21, 2024 · 30ac033 · 30ac033
1 parent 4e2f6fb
commit 30ac033
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/src/execution/datafusion/expressions/variance.rs b/core/src/execution/datafusion/expressions/variance.rs
@@ -235,8 +235,8 @@ impl Accumulator for VarianceAccumulator {
         };
 
         Ok(ScalarValue::Float64(match self.count {
-            0.0 => None,
-            1.0 => {
+            count if count == 0.0 => None,
+            count if count == 1.0 => {
                 if let StatsType::Population = self.stats_type {
                     Some(0.0)
                 } else if self.null_on_divide_by_zero {
@@ -245,7 +245,7 @@ impl Accumulator for VarianceAccumulator {
                     Some(f64::NAN)
                 }
             }
-            _ => Some(self.m2 / count),
+            _ => Some(self.m2 / self.count),
         }))
     }