diff options
author | Joseph K. Bradley <joseph@databricks.com> | 2016-05-26 22:36:43 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-05-26 22:36:43 -0700 |
commit | ee3609a2ef55ae5a2797e5ffe06c2849cbd11e15 (patch) | |
tree | 545616808c2db119b95a13fff758792253a2cd3d | |
parent | c82883239eadc4615a3aba907cd4633cb7aed26e (diff) | |
download | spark-ee3609a2ef55ae5a2797e5ffe06c2849cbd11e15.tar.gz spark-ee3609a2ef55ae5a2797e5ffe06c2849cbd11e15.tar.bz2 spark-ee3609a2ef55ae5a2797e5ffe06c2849cbd11e15.zip |
[MINOR][CORE] Fixed doc for Accumulator2.add
## What changes were proposed in this pull request?
Scala doc used outdated ```+=```. Replaced with ```add```.
## How was this patch tested?
N/A
Author: Joseph K. Bradley <joseph@databricks.com>
Closes #13346 from jkbradley/accum-doc.
-rw-r--r-- | core/src/main/scala/org/apache/spark/SparkContext.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index 5018eb38d9..5aba2a8c94 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -1304,7 +1304,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli } /** - * Create and register a long accumulator, which starts with 0 and accumulates inputs by `+=`. + * Create and register a long accumulator, which starts with 0 and accumulates inputs by `add`. */ def longAccumulator: LongAccumulator = { val acc = new LongAccumulator @@ -1313,7 +1313,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli } /** - * Create and register a long accumulator, which starts with 0 and accumulates inputs by `+=`. + * Create and register a long accumulator, which starts with 0 and accumulates inputs by `add`. */ def longAccumulator(name: String): LongAccumulator = { val acc = new LongAccumulator @@ -1322,7 +1322,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli } /** - * Create and register a double accumulator, which starts with 0 and accumulates inputs by `+=`. + * Create and register a double accumulator, which starts with 0 and accumulates inputs by `add`. */ def doubleAccumulator: DoubleAccumulator = { val acc = new DoubleAccumulator @@ -1331,7 +1331,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli } /** - * Create and register a double accumulator, which starts with 0 and accumulates inputs by `+=`. + * Create and register a double accumulator, which starts with 0 and accumulates inputs by `add`. */ def doubleAccumulator(name: String): DoubleAccumulator = { val acc = new DoubleAccumulator |