Skip to content

Commit 316ad77

Browse files
author
Saldanha
committed
SPARK-4459 changed type parameter for groupBy from K to U.
1 parent 62ddd4b commit 316ad77

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -212,8 +212,8 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends Serializable {
212212
* Return an RDD of grouped elements. Each group consists of a key and a sequence of elements
213213
* mapping to that key.
214214
*/
215-
def groupBy[K](f: JFunction[T, K]): JavaPairRDD[K, JIterable[T]] = {
216-
implicit val ctagK: ClassTag[K] = fakeClassTag
215+
def groupBy[U](f: JFunction[T, U]): JavaPairRDD[U, JIterable[T]] = {
216+
implicit val ctagK: ClassTag[U] = fakeClassTag
217217
implicit val ctagV: ClassTag[JList[T]] = fakeClassTag
218218
JavaPairRDD.fromRDD(groupByResultToJava(rdd.groupBy(f)(fakeClassTag)))
219219
}
@@ -222,10 +222,10 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends Serializable {
222222
* Return an RDD of grouped elements. Each group consists of a key and a sequence of elements
223223
* mapping to that key.
224224
*/
225-
def groupBy[K](f: JFunction[T, K], numPartitions: Int): JavaPairRDD[K, JIterable[T]] = {
226-
implicit val ctagK: ClassTag[K] = fakeClassTag
225+
def groupBy[U](f: JFunction[T, U], numPartitions: Int): JavaPairRDD[U, JIterable[T]] = {
226+
implicit val ctagK: ClassTag[U] = fakeClassTag
227227
implicit val ctagV: ClassTag[JList[T]] = fakeClassTag
228-
JavaPairRDD.fromRDD(groupByResultToJava(rdd.groupBy(f, numPartitions)(fakeClassTag[K])))
228+
JavaPairRDD.fromRDD(groupByResultToJava(rdd.groupBy(f, numPartitions)(fakeClassTag[U])))
229229
}
230230

231231
/**

0 commit comments

Comments
 (0)