added max and min to StatCounter output, updated doc

yinxusen · Mar 15, 2014 · 21dd366 · 21dd366
1 parent 1a97558
commit 21dd366
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/util/StatCounter.scala b/core/src/main/scala/org/apache/spark/util/StatCounter.scala
@@ -29,8 +29,8 @@ class StatCounter(values: TraversableOnce[Double]) extends Serializable {
   private var n: Long = 0     // Running count of our values
   private var mu: Double = 0  // Running mean of our values
   private var m2: Double = 0  // Running variance numerator (sum of (x - mean)^2)
-  private var max_v: Double = Double(-Infinity) // Running max of our values
-  private var min_v: Double = Double(Infinity) // Running min of our values
+  private var max_v: Double = Double.PositiveInfinity // Running max of our values
+  private var min_v: Double = Double.NegativeInfinity // Running min of our values
 
   merge(values)