diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-10-01 10:57:26 -0700 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-10-01 10:57:26 -0700 |
commit | 0b84871dbca8a1a33407e7322e3c6162d24b4c29 (patch) | |
tree | 4123edae06900e676ac2e2fc131d2bd31f9bf96c | |
parent | 53f90d0f0ea8ae605e95ece9850df6004123c787 (diff) | |
download | spark-0b84871dbca8a1a33407e7322e3c6162d24b4c29.tar.gz spark-0b84871dbca8a1a33407e7322e3c6162d24b4c29.tar.bz2 spark-0b84871dbca8a1a33407e7322e3c6162d24b4c29.zip |
Remove some printlns in tests
-rw-r--r-- | core/src/test/scala/spark/JavaAPISuite.java | 6 | ||||
-rw-r--r-- | core/src/test/scala/spark/PipedRDDSuite.scala | 1 |
2 files changed, 5 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/JavaAPISuite.java b/core/src/test/scala/spark/JavaAPISuite.java index 24bf021710..5875506179 100644 --- a/core/src/test/scala/spark/JavaAPISuite.java +++ b/core/src/test/scala/spark/JavaAPISuite.java @@ -112,15 +112,19 @@ public class JavaAPISuite implements Serializable { Assert.assertEquals(new Tuple2<Integer, Integer>(3, 2), sortedPairs.get(2)); } + static int foreachCalls = 0; + @Test public void foreach() { + foreachCalls = 0; JavaRDD<String> rdd = sc.parallelize(Arrays.asList("Hello", "World")); rdd.foreach(new VoidFunction<String>() { @Override public void call(String s) { - System.out.println(s); + foreachCalls++; } }); + Assert.assertEquals(2, foreachCalls); } @Test diff --git a/core/src/test/scala/spark/PipedRDDSuite.scala b/core/src/test/scala/spark/PipedRDDSuite.scala index 426652dc15..add5221e30 100644 --- a/core/src/test/scala/spark/PipedRDDSuite.scala +++ b/core/src/test/scala/spark/PipedRDDSuite.scala @@ -22,7 +22,6 @@ class PipedRDDSuite extends FunSuite with BeforeAndAfter { val piped = nums.pipe(Seq("cat")) val c = piped.collect() - println(c.toSeq) assert(c.size === 4) assert(c(0) === "1") assert(c(1) === "2") |