diff options
author | Patrick Wendell <pwendell@gmail.com> | 2013-01-04 11:21:46 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2013-01-14 09:42:36 -0800 |
commit | b0974e6c1d1d8e03d9b70660070f66977ea2e797 (patch) | |
tree | 5f4f7ddd4d90f7ae3f82790112d1a317b20a78f8 /streaming | |
parent | 867a7455e27af9e8a6b95c87c882c0eebcaed0ad (diff) | |
download | spark-b0974e6c1d1d8e03d9b70660070f66977ea2e797.tar.gz spark-b0974e6c1d1d8e03d9b70660070f66977ea2e797.tar.bz2 spark-b0974e6c1d1d8e03d9b70660070f66977ea2e797.zip |
Remving main method from tests
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/test/scala/spark/streaming/JavaAPISuite.java | 27 |
1 files changed, 0 insertions, 27 deletions
diff --git a/streaming/src/test/scala/spark/streaming/JavaAPISuite.java b/streaming/src/test/scala/spark/streaming/JavaAPISuite.java index 5327edfd5d..9cf0341cce 100644 --- a/streaming/src/test/scala/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/scala/spark/streaming/JavaAPISuite.java @@ -67,31 +67,4 @@ public class JavaAPISuite implements Serializable { Assert.assertTrue(result.equals( Arrays.asList(Arrays.asList(5, 5), Arrays.asList(9, 4)))); } - - public static void main(String[] args) { - JavaStreamingContext sc = new JavaStreamingContext("local[2]", "test", new Time(1000)); - - sc.networkTextStream("localhost", 12345).map(new Function<String, Integer>() { - @Override - public Integer call(String s) throws Exception { - return s.length(); - } - }).reduce(new Function2<Integer, Integer, Integer>() { - @Override - public Integer call(Integer i1, Integer i2) throws Exception { - return i1 + i2; - } - }).foreach(new Function2<JavaRDD<Integer>, Time, Void>() { - @Override - public Void call(JavaRDD<Integer> integerJavaRDD, Time t) throws Exception { - System.out.println("Contents @ " + t.toFormattedString()); - for (int i: integerJavaRDD.collect()) { - System.out.println(i + "\n"); - } - return null; - } - }); - - sc.start(); - } } |