Skip to content

Commit 32129b4

Browse files
committed
Fix comments in @Aggregator and @mapSideCombine
1 parent 303c75d commit 32129b4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,8 @@ abstract class NarrowDependency[T](_rdd: RDD[T]) extends Dependency[T] {
6161
* the default serializer, as specified by `spark.serializer` config option, will
6262
* be used.
6363
* @param keyOrdering key ordering for RDD's shuffles
64-
* @param aggregator map-side aggregator for RDD's shuffle
65-
* @param mapSideCombine map-side aggregation flag
64+
* @param aggregator map/reduce-side aggregator for RDD's shuffle
65+
* @param mapSideCombine whether to perform partial aggregation (also known as map-side combine)
6666
*/
6767
@DeveloperApi
6868
class ShuffleDependency[K, V, C](

0 commit comments

Comments
 (0)