Remove default param 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/fa42951e Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/fa42951e Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/fa42951e Branch: refs/heads/master Commit: fa42951e3bbd5af2d65d11e91101a775a2bd3c3f Parents: 8fe562c Author: eklavya <sr.ekla...@gmail.com> Authored: Mon Jan 13 18:13:22 2014 +0530 Committer: eklavya <sr.ekla...@gmail.com> Committed: Mon Jan 13 18:13:22 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/fa42951e/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 52265bb..e7b1cee 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 @@ -145,7 +145,7 @@ JavaRDDLike[T, JavaRDD[T]] { * Return a new RDD by applying a function to each partition of this RDD. */ def mapPartitions[U]( - f: JFMap[JIterator[T], U], preservesPartitioning: Boolean = false): JavaRDD[U] = { + f: JFMap[JIterator[T], U], preservesPartitioning: Boolean): JavaRDD[U] = { rdd.mapPartitions[U]((x => f(asJavaIterator(x)).iterator), preservesPartitioning) }
