use last for the last element

mengxr · mengxr · commit cab9a52349a7 · 2014-03-15T11:06:32.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/rdd/SlidingRDD.scala b/core/src/main/scala/org/apache/spark/rdd/SlidingRDD.scala
@@ -90,7 +90,7 @@ class SlidingRDD[T: ClassTag](@transient val parent: RDD[T], val windowSize: Int
         i = j
       }
       // If the head of last partition has size w1, we also need to add this partition.
-      if (nextHeads(n1 - 1).size == w1) {
+      if (nextHeads.last.size == w1) {
         partitions += new SlidingRDDPartition[T](partitionIndex, parentPartitions(n1), Seq.empty)
       }
       partitions.toArray

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ class SlidingRDD[T: ClassTag](@transient val parent: RDD[T], val windowSize: Int`
`90`	`90`	`i = j`
`91`	`91`	`}`
`92`	`92`	`// If the head of last partition has size w1, we also need to add this partition.`
`93`		`- if (nextHeads(n1 - 1).size == w1) {`
	`93`	`+ if (nextHeads.last.size == w1) {`
`94`	`94`	`partitions += new SlidingRDDPartition[T](partitionIndex, parentPartitions(n1), Seq.empty)`
`95`	`95`	`}`
`96`	`96`	`partitions.toArray`