minor change

kanzhang · kanzhang · commit 67c33b5e7a82 · 2014-05-15T11:18:09.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala b/core/src/main/scala/org/apache/spark/rdd/ParallelCollectionRDD.scala
@@ -119,7 +119,7 @@ private object ParallelCollectionRDD {
     }
     // Sequences need to be sliced at same positions for operations
     // like RDD.zip() to behave as expected
-    def positions(length: Long, numSlices: Int): Seq[(Int, Int)] = {
+    def positions(length: Long, numSlices: Int) = {
       (0 until numSlices).map(i => {
         val start = ((i * length) / numSlices).toInt
         val end = (((i + 1) * length) / numSlices).toInt

Original file line number	Diff line number	Diff line change
`@@ -119,7 +119,7 @@ private object ParallelCollectionRDD {`
`119`	`119`	`}`
`120`	`120`	`// Sequences need to be sliced at same positions for operations`
`121`	`121`	`// like RDD.zip() to behave as expected`
`122`		`- def positions(length: Long, numSlices: Int): Seq[(Int, Int)] = {`
	`122`	`+ def positions(length: Long, numSlices: Int) = {`
`123`	`123`	`(0 until numSlices).map(i => {`
`124`	`124`	`val start = ((i * length) / numSlices).toInt`
`125`	`125`	`val end = (((i + 1) * length) / numSlices).toInt`