You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2014/01/23 20:14:32 UTC
[4/9] git commit: Remove classtag from mapPartitions.
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...@gmail.com>
Authored: Mon Jan 13 18:09:58 2014 +0530
Committer: eklavya <sr...@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)
}