SPARK-1259 Make RDD locally iterable

epahomov · epahomov · commit 6a994eb87a84 · 2014-03-18T12:14:43.000+04:00
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
@@ -291,7 +291,7 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends Serializable {
     new JIterable[T](){
       def iterator(): JIterator[T] =  {
         import scala.collection.JavaConversions._
-        asJavaIterator(rdd.toLocallyIterable.iterator)
+        rdd.toLocallyIterable.iterator
       }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -291,7 +291,7 @@ trait JavaRDDLike[T, This <: JavaRDDLike[T, This]] extends Serializable {`
`291`	`291`	`new JIterable[T](){`
`292`	`292`	`def iterator(): JIterator[T] = {`
`293`	`293`	`import scala.collection.JavaConversions._`
`294`		`- asJavaIterator(rdd.toLocallyIterable.iterator)`
	`294`	`+ rdd.toLocallyIterable.iterator`
`295`	`295`	`}`
`296`	`296`	`}`
`297`	`297`	`}`