Skip to content

Commit ee3609a

Browse files
jkbradleyrxin
authored andcommitted
[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 <[email protected]> Closes apache#13346 from jkbradley/accum-doc.
1 parent c828832 commit ee3609a

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

core/src/main/scala/org/apache/spark/SparkContext.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1304,7 +1304,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
13041304
}
13051305

13061306
/**
1307-
* Create and register a long accumulator, which starts with 0 and accumulates inputs by `+=`.
1307+
* Create and register a long accumulator, which starts with 0 and accumulates inputs by `add`.
13081308
*/
13091309
def longAccumulator: LongAccumulator = {
13101310
val acc = new LongAccumulator
@@ -1313,7 +1313,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
13131313
}
13141314

13151315
/**
1316-
* Create and register a long accumulator, which starts with 0 and accumulates inputs by `+=`.
1316+
* Create and register a long accumulator, which starts with 0 and accumulates inputs by `add`.
13171317
*/
13181318
def longAccumulator(name: String): LongAccumulator = {
13191319
val acc = new LongAccumulator
@@ -1322,7 +1322,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
13221322
}
13231323

13241324
/**
1325-
* Create and register a double accumulator, which starts with 0 and accumulates inputs by `+=`.
1325+
* Create and register a double accumulator, which starts with 0 and accumulates inputs by `add`.
13261326
*/
13271327
def doubleAccumulator: DoubleAccumulator = {
13281328
val acc = new DoubleAccumulator
@@ -1331,7 +1331,7 @@ class SparkContext(config: SparkConf) extends Logging with ExecutorAllocationCli
13311331
}
13321332

13331333
/**
1334-
* Create and register a double accumulator, which starts with 0 and accumulates inputs by `+=`.
1334+
* Create and register a double accumulator, which starts with 0 and accumulates inputs by `add`.
13351335
*/
13361336
def doubleAccumulator(name: String): DoubleAccumulator = {
13371337
val acc = new DoubleAccumulator

0 commit comments

Comments
 (0)