Remove classtag from mapPartitions.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/8fe562c0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/8fe562c0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/8fe562c0 Branch: refs/heads/master Commit: 8fe562c0fac25c710fc50e97690f3bca5b5e4d59 Parents: 6a65fee Author: eklavya <sr.ekla...@gmail.com> Authored: Mon Jan 13 18:09:58 2014 +0530 Committer: eklavya <sr.ekla...@gmail.com> Committed: Mon Jan 13 18:09:58 2014 +0530 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/8fe562c0/core/src/main/scala/org/apache/spark/api/java/JavaRDD.scala ---------------------------------------------------------------------- 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 bd77855..52265bb 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) }
