aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJoseph K. Bradley <joseph@databricks.com>2016-05-26 22:36:43 -0700
committerReynold Xin <rxin@databricks.com>2016-05-26 22:36:43 -0700
commitee3609a2ef55ae5a2797e5ffe06c2849cbd11e15 (patch)
tree545616808c2db119b95a13fff758792253a2cd3d
parentc82883239eadc4615a3aba907cd4633cb7aed26e (diff)
downloadspark-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.scala8
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