diff options
| author | Holden Karau <holden@pigscanfly.ca> | 2013-09-23 19:39:42 -0700 |
|---|---|---|
| committer | Holden Karau <holden@pigscanfly.ca> | 2013-09-23 19:39:42 -0700 |
| commit | 0cef683553414ba880d90527cc5f37e119efc782 (patch) | |
| tree | 8fc95d5d8f97bbc89b2102f9f908d3d8d43d4454 /core/src/main | |
| parent | 7fe0b0ff568e8cf43efaabf46ac760cc8b91cf79 (diff) | |
| download | spark-0cef683553414ba880d90527cc5f37e119efc782.tar.gz spark-0cef683553414ba880d90527cc5f37e119efc782.tar.bz2 spark-0cef683553414ba880d90527cc5f37e119efc782.zip | |
Fix formatting :)
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala b/core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala index b932c7c7cd..7a3568c5ef 100644 --- a/core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala +++ b/core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala @@ -71,10 +71,11 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends Serializable { * Return a new RDD by applying a function to each partition of this RDD, while tracking the index * of the original partition. */ - def mapPartitionsWithIndex[R: ClassManifest](f: JFunction2[Int, java.util.Iterator[T], java.util.Iterator[R]], - preservesPartitioning: Boolean = false): JavaRDD[R] = - new JavaRDD(rdd.mapPartitionsWithIndex(((a,b) => f(a,asJavaIterator(b))), - preservesPartitioning)) + def mapPartitionsWithIndex[R: ClassManifest]( + f: JFunction2[Int, java.util.Iterator[T], java.util.Iterator[R]], + preservesPartitioning: Boolean = false): JavaRDD[R] = + new JavaRDD(rdd.mapPartitionsWithIndex(((a,b) => f(a,asJavaIterator(b))), + preservesPartitioning)) /** * Return a new RDD by applying a function to all elements of this RDD. |