diff options
| author | eklavya <sr.eklavya@gmail.com> | 2014-01-13 18:09:58 +0530 |
|---|---|---|
| committer | eklavya <sr.eklavya@gmail.com> | 2014-01-13 18:09:58 +0530 |
| commit | 8fe562c0fac25c710fc50e97690f3bca5b5e4d59 (patch) | |
| tree | 81a3fd0b0b8ce4d4cc99d3d796d76aab19f78525 /core | |
| parent | 6a65feebc708b236625a7b5859981630206cf9d3 (diff) | |
| download | spark-8fe562c0fac25c710fc50e97690f3bca5b5e4d59.tar.gz spark-8fe562c0fac25c710fc50e97690f3bca5b5e4d59.tar.bz2 spark-8fe562c0fac25c710fc50e97690f3bca5b5e4d59.zip | |
Remove classtag from mapPartitions.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala b/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala index bd778550af..52265bbf4d 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala @@ -144,7 +144,7 @@ JavaRDDLike[T, JavaRDD[T]] { /** * Return a new RDD by applying a function to each partition of this RDD. */ - def mapPartitions[U: ClassTag]( + def mapPartitions[U]( f: JFMap[JIterator[T], U], preservesPartitioning: Boolean = false): JavaRDD[U] = { rdd.mapPartitions[U]((x => f(asJavaIterator(x)).iterator), preservesPartitioning) } |