diff options
author | eklavya <sr.eklavya@gmail.com> | 2014-01-13 18:13:22 +0530 |
---|---|---|
committer | eklavya <sr.eklavya@gmail.com> | 2014-01-13 18:13:22 +0530 |
commit | fa42951e3bbd5af2d65d11e91101a775a2bd3c3f (patch) | |
tree | 4675c840e9753a894cfe88acdcd546c98ad8069d /core | |
parent | 8fe562c0fac25c710fc50e97690f3bca5b5e4d59 (diff) | |
download | spark-fa42951e3bbd5af2d65d11e91101a775a2bd3c3f.tar.gz spark-fa42951e3bbd5af2d65d11e91101a775a2bd3c3f.tar.bz2 spark-fa42951e3bbd5af2d65d11e91101a775a2bd3c3f.zip |
Remove default param 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 52265bbf4d..e7b1ceebf6 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) } |