diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-18 15:18:34 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-18 15:18:34 -0800 |
commit | 12ea14c211da908a278ab19fd1e9f6acd45daae8 (patch) | |
tree | 4f76d48f589f23185b680164cedaa9204af8784d /streaming/src/test/java | |
parent | 6a6e6bda5713ccc6da9ca977321a1fcc6d38a1c1 (diff) | |
download | spark-12ea14c211da908a278ab19fd1e9f6acd45daae8.tar.gz spark-12ea14c211da908a278ab19fd1e9f6acd45daae8.tar.bz2 spark-12ea14c211da908a278ab19fd1e9f6acd45daae8.zip |
Changed networkStream to socketStream and pluggableNetworkStream to become networkStream as a way to create streams from arbitrary network receiver.
Diffstat (limited to 'streaming/src/test/java')
-rw-r--r-- | streaming/src/test/java/spark/streaming/JavaAPISuite.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java index 16bacffb92..5d510fd89f 100644 --- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java @@ -23,7 +23,6 @@ import spark.streaming.JavaCheckpointTestUtils; import spark.streaming.dstream.KafkaPartitionKey; import java.io.*; -import java.text.Collator; import java.util.*; // The test suite itself is Serializable so that anonymous Function implementations can be @@ -984,7 +983,7 @@ public class JavaAPISuite implements Serializable { @Test public void testNetworkTextStream() { - JavaDStream test = ssc.networkTextStream("localhost", 12345); + JavaDStream test = ssc.socketTextStream("localhost", 12345); } @Test @@ -1004,7 +1003,7 @@ public class JavaAPISuite implements Serializable { } } - JavaDStream test = ssc.networkStream( + JavaDStream test = ssc.socketStream( "localhost", 12345, new Converter(), |