diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-23 16:25:07 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-23 16:25:07 -0800 |
| commit | 41285eaae3642b73b3ac5007a35cc4e8f1d7d084 (patch) | |
| tree | 7347664e7474271a1ca534b95c8b731f28045082 /examples | |
| parent | d8cee52d526497efdc02ea39e2fb721321ec0b4e (diff) | |
| download | spark-41285eaae3642b73b3ac5007a35cc4e8f1d7d084.tar.gz spark-41285eaae3642b73b3ac5007a35cc4e8f1d7d084.tar.bz2 spark-41285eaae3642b73b3ac5007a35cc4e8f1d7d084.zip | |
Fixed differences in APIs of StreamingContext and JavaStreamingContext. Change rawNetworkStream to rawSocketStream, and added twitter, actor, zeroMQ streams to JavaStreamingContext. Also added them to JavaAPISuite.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala b/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala index 2eec777c54..66e709b7a3 100644 --- a/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala +++ b/examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala @@ -37,7 +37,7 @@ object RawNetworkGrep { RawTextHelper.warmUp(ssc.sc) val rawStreams = (1 to numStreams).map(_ => - ssc.rawNetworkStream[String](host, port, StorageLevel.MEMORY_ONLY_SER_2)).toArray + ssc.rawSocketStream[String](host, port, StorageLevel.MEMORY_ONLY_SER_2)).toArray val union = ssc.union(rawStreams) union.filter(_.contains("the")).count().foreach(r => println("Grep count: " + r.collect().mkString)) |