diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-02-20 12:33:37 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-02-20 19:14:52 +0530 |
| commit | 4e5b09664cdf95effff61c042b6243107355b55c (patch) | |
| tree | f77387624bef2cc193ff009af438433060f42926 /streaming | |
| parent | 8d44480d840079cb444b5e19511e5027dedd7f77 (diff) | |
| download | spark-4e5b09664cdf95effff61c042b6243107355b55c.tar.gz spark-4e5b09664cdf95effff61c042b6243107355b55c.tar.bz2 spark-4e5b09664cdf95effff61c042b6243107355b55c.zip | |
fixes corresponding to review feedback at pull request #479
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/StreamingContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/spark/streaming/StreamingContext.scala index f15e6bd23d..2ca7dcc218 100644 --- a/streaming/src/main/scala/spark/streaming/StreamingContext.scala +++ b/streaming/src/main/scala/spark/streaming/StreamingContext.scala @@ -177,7 +177,7 @@ class StreamingContext private ( } /** - * ZeroMQ stream receiver + * Create an input stream that receives messages pushed by a zeromq publisher. * @param publisherUrl Url of remote zeromq publisher * @param zeroMQ topic to subscribe to * @param bytesToObjects A zeroMQ stream publishes sequence of frames for each topic and each frame has sequence |