From fd0374b9de2e32d55fb14c371a98f0f39c30a17a Mon Sep 17 00:00:00 2001 From: Matei Zaharia <matei@eecs.berkeley.edu> Date: Sat, 29 Sep 2012 21:43:06 -0700 Subject: [PATCH] Comment --- core/src/main/scala/spark/CoalescedRDD.scala | 2 +- core/src/test/scala/spark/RDDSuite.scala | 2 +- 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)) -- GitLab