-
- Downloads
[SPARK-15079] Support average/count/sum in Long/DoubleAccumulator
## What changes were proposed in this pull request? This patch removes AverageAccumulator and adds the ability to compute average to LongAccumulator and DoubleAccumulator. The patch also improves documentation for the two accumulators. ## How was this patch tested? Added unit tests for this. Author: Reynold Xin <rxin@databricks.com> Closes #12858 from rxin/SPARK-15079.
Showing
- core/src/main/scala/org/apache/spark/Accumulator.scala 0 additions, 17 deletionscore/src/main/scala/org/apache/spark/Accumulator.scala
- core/src/main/scala/org/apache/spark/AccumulatorV2.scala 91 additions, 46 deletionscore/src/main/scala/org/apache/spark/AccumulatorV2.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 0 additions, 22 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/test/scala/org/apache/spark/AccumulatorSuite.scala 1 addition, 16 deletionscore/src/test/scala/org/apache/spark/AccumulatorSuite.scala
- core/src/test/scala/org/apache/spark/util/AccumulatorV2Suite.scala 89 additions, 0 deletions...test/scala/org/apache/spark/util/AccumulatorV2Suite.scala
Loading
Please register or sign in to comment