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 /examples/src/main/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 'examples/src/main/java')
| -rw-r--r-- | examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java b/examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java index 4299febfd6..07342beb02 100644 --- a/examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java +++ b/examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java @@ -35,7 +35,7 @@ public class JavaNetworkWordCount { // Create a NetworkInputDStream on target ip:port and count the // words in input stream of \n delimited test (eg. generated by 'nc') - JavaDStream<String> lines = ssc.networkTextStream(args[1], Integer.parseInt(args[2])); + JavaDStream<String> lines = ssc.socketTextStream(args[1], Integer.parseInt(args[2])); JavaDStream<String> words = lines.flatMap(new FlatMapFunction<String, String>() { @Override public Iterable<String> call(String x) { |