diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-31 00:38:19 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-31 00:38:19 -0800 |
commit | 3ab297adaae153cd76c9893ab62e0a815ec21fa4 (patch) | |
tree | a97aee8c96abf1f51c1b5d2c23f31cd222f66eb2 /streaming/src/test/java | |
parent | 97630849ff2cdaa2ff8a115c3e8e6ca8dba7477d (diff) | |
download | spark-3ab297adaae153cd76c9893ab62e0a815ec21fa4.tar.gz spark-3ab297adaae153cd76c9893ab62e0a815ec21fa4.tar.bz2 spark-3ab297adaae153cd76c9893ab62e0a815ec21fa4.zip |
Removed unnecessary comments.
Diffstat (limited to 'streaming/src/test/java')
-rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java index f4d26c0be6..62187957d6 100644 --- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java @@ -1600,30 +1600,4 @@ public class JavaAPISuite extends LocalJavaStreamingContext implements Serializa public void testRawSocketStream() { JavaDStream<String> test = ssc.rawSocketStream("localhost", 12345); } - /* - @Test - public void testFileStream() { - JavaPairDStream<String, String> foo = ssc.<String, String, SequenceFileInputFormat<String,String>>fileStream("/tmp/foo"); - } - - @Test - public void testTwitterStream() { - String[] filters = new String[] { "good", "bad", "ugly" }; - JavaDStream<Status> test = ssc.twitterStream(filters, StorageLevel.MEMORY_ONLY()); - } - - @Test - public void testActorStream() { - JavaDStream<String> test = ssc.actorStream((Props)null, "TestActor", StorageLevel.MEMORY_ONLY()); - } - - @Test - public void testZeroMQStream() { - JavaDStream<String> test = ssc.zeroMQStream("url", (Subscribe) null, new Function<byte[][], Iterable<String>>() { - @Override - public Iterable<String> call(byte[][] b) throws Exception { - return null; - } - }); - } */ } |