Skip to content

Commit 2906e74

Browse files
committed
Scaladoc cleanup
1 parent eccb0ed commit 2906e74

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -105,9 +105,9 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
105105
}
106106

107107
/**
108-
* This method is here for backward compatibility. It
109-
* does not provide combiner classtag information to
110-
* the shuffle.
108+
* Generic function to combine the elements for each key using a custom set of aggregation
109+
* functions. This method is here for backward compatibility. It does not provide combiner
110+
* classtag information to the shuffle.
111111
*
112112
* @see [[combineByKeyWithClassTag]]
113113
*/
@@ -123,9 +123,9 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
123123
}
124124

125125
/**
126-
* This method is here for backward compatibility. It
127-
* does not provide combiner classtag information to
128-
* the shuffle.
126+
* Simplified version of combineByKeyWithClassTag that hash-partitions the output RDD.
127+
* This method is here for backward compatibility. It does not provide combiner
128+
* classtag information to the shuffle.
129129
*
130130
* @see [[combineByKeyWithClassTag]]
131131
*/
@@ -605,9 +605,9 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
605605
}
606606

607607
/**
608-
* This method is here for backward compatibility. It
609-
* does not provide combiner classtag information to
610-
* the shuffle.
608+
* Simplified version of combineByKeyWithClassTag that hash-partitions the resulting RDD using the
609+
* existing partitioner/parallelism level. This method is here for backward compatibility. It
610+
* does not provide combiner classtag information to the shuffle.
611611
*
612612
* @see [[combineByKeyWithClassTag]]
613613
*/

0 commit comments

Comments
 (0)