You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2013/09/26 22:49:21 UTC
[6/7] git commit: Fix formatting :)
Fix formatting :)
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/0cef6835
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/0cef6835
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/0cef6835
Branch: refs/heads/master
Commit: 0cef683553414ba880d90527cc5f37e119efc782
Parents: 7fe0b0f
Author: Holden Karau <ho...@pigscanfly.ca>
Authored: Mon Sep 23 19:39:42 2013 -0700
Committer: Holden Karau <ho...@pigscanfly.ca>
Committed: Mon Sep 23 19:39:42 2013 -0700
----------------------------------------------------------------------
.../main/scala/org/apache/spark/api/java/JavaRDDLike.scala | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/0cef6835/core/src/main/scala/org/apache/spark/api/java/JavaRDDLike.scala
----------------------------------------------------------------------
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 b932c7c..7a3568c 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.