diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-05 13:07:59 -0600 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-05 13:07:59 -0600 |
| commit | 1fdb6946b5d076ed0f1b4d2bca2a20b6cd22cbc3 (patch) | |
| tree | 278ced89147fed0526b0ace93cde2a8c963859e5 /core/src/test | |
| parent | 55809fbc6db5929332cd45fa3281f9190098c6c6 (diff) | |
| download | spark-1fdb6946b5d076ed0f1b4d2bca2a20b6cd22cbc3.tar.gz spark-1fdb6946b5d076ed0f1b4d2bca2a20b6cd22cbc3.tar.bz2 spark-1fdb6946b5d076ed0f1b4d2bca2a20b6cd22cbc3.zip | |
Add RDD.tupleBy.
Diffstat (limited to 'core/src/test')
| -rw-r--r-- | core/src/test/scala/spark/RDDSuite.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/core/src/test/scala/spark/RDDSuite.scala b/core/src/test/scala/spark/RDDSuite.scala index 45e6c5f840..7832884224 100644 --- a/core/src/test/scala/spark/RDDSuite.scala +++ b/core/src/test/scala/spark/RDDSuite.scala @@ -35,6 +35,7 @@ class RDDSuite extends FunSuite with BeforeAndAfter { assert(nums.flatMap(x => 1 to x).collect().toList === List(1, 1, 2, 1, 2, 3, 1, 2, 3, 4)) assert(nums.union(nums).collect().toList === List(1, 2, 3, 4, 1, 2, 3, 4)) assert(nums.glom().map(_.toList).collect().toList === List(List(1, 2), List(3, 4))) + assert(nums.tupleBy(_.toString).collect().toList === List(("1", 1), ("2", 2), ("3", 3), ("4", 4))) val partitionSums = nums.mapPartitions(iter => Iterator(iter.reduceLeft(_ + _))) assert(partitionSums.collect().toList === List(3, 7)) |