aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2012-09-29 21:43:06 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2012-09-29 21:43:06 -0700
commitfd0374b9de2e32d55fb14c371a98f0f39c30a17a (patch)
tree25b4a03cd50c2e4acbe62f805d1798badfe6281e
parent5718cef2a40cb06ba1fb05ccca459fd87b5ec93d (diff)
downloadspark-fd0374b9de2e32d55fb14c371a98f0f39c30a17a.tar.gz
spark-fd0374b9de2e32d55fb14c371a98f0f39c30a17a.tar.bz2
spark-fd0374b9de2e32d55fb14c371a98f0f39c30a17a.zip
Comment
-rw-r--r--core/src/main/scala/spark/CoalescedRDD.scala2
-rw-r--r--core/src/test/scala/spark/RDDSuite.scala2
2 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/CoalescedRDD.scala b/core/src/main/scala/spark/CoalescedRDD.scala
index ac0627a4c2..f1ae346a44 100644
--- a/core/src/main/scala/spark/CoalescedRDD.scala
+++ b/core/src/main/scala/spark/CoalescedRDD.scala
@@ -4,7 +4,7 @@ private class CoalescedRDDSplit(val index: Int, val parents: Array[Split]) exten
/**
* Coalesce the partitions of a parent RDD (`prev`) into fewer partitions, so that each partition of
- * this RDD computes zero or more of the parent ones. Will produce exactly `maxPartitions` if the
+ * this RDD computes one or more of the parent ones. Will produce exactly `maxPartitions` if the
* parent had more than this many partitions, or fewer if the parent had fewer.
*
* This transformation is useful when an RDD with many partitions gets filtered into a smaller one,
diff --git a/core/src/test/scala/spark/RDDSuite.scala b/core/src/test/scala/spark/RDDSuite.scala
index 961d05bc82..a1fe63beaf 100644
--- a/core/src/test/scala/spark/RDDSuite.scala
+++ b/core/src/test/scala/spark/RDDSuite.scala
@@ -79,7 +79,7 @@ class RDDSuite extends FunSuite with BeforeAndAfter {
val coalesced1 = new CoalescedRDD(data, 2)
assert(coalesced1.collect().toList === (1 to 10).toList)
assert(coalesced1.glom().collect().map(_.toList).toList ===
- List(List(1, 2, 3, 4, 5), List(6, 7, 8, 9, 10)))
+ List(List(1, 2, 3, 4, 5), List(6, 7, 8, 9, 10)))
// Check that the narrow dependency is also specified correctly
assert(coalesced1.dependencies.head.getParents(0).toList === List(0, 1, 2, 3, 4))