aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authoreklavya <sr.eklavya@gmail.com>2014-01-13 18:13:22 +0530
committereklavya <sr.eklavya@gmail.com>2014-01-13 18:13:22 +0530
commitfa42951e3bbd5af2d65d11e91101a775a2bd3c3f (patch)
tree4675c840e9753a894cfe88acdcd546c98ad8069d /core
parent8fe562c0fac25c710fc50e97690f3bca5b5e4d59 (diff)
downloadspark-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.scala2
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)
}