diff options
author | chriskang90 <jckang@uchicago.edu> | 2015-11-09 19:39:22 +0100 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2015-11-09 19:39:22 +0100 |
commit | 874cd66d4b6d156d0ef112a3d0f3bc5683c6a0ec (patch) | |
tree | aa69cafe960a8a3a8b55cfecafd625b94db89736 | |
parent | cd174882a5a211298d6e173fe989d567d08ebc0d (diff) | |
download | spark-874cd66d4b6d156d0ef112a3d0f3bc5683c6a0ec.tar.gz spark-874cd66d4b6d156d0ef112a3d0f3bc5683c6a0ec.tar.bz2 spark-874cd66d4b6d156d0ef112a3d0f3bc5683c6a0ec.zip |
[DOCS] Fix typo for Python section on unifying Kafka streams
1) kafkaStreams is a list. The list should be unpacked when passing it into the streaming context union method, which accepts a variable number of streams.
2) print() should be pprint() for pyspark.
This contribution is my original work, and I license the work to the project under the project's open source license.
Author: chriskang90 <jckang@uchicago.edu>
Closes #9545 from c-kang/streaming_python_typo.
-rw-r--r-- | docs/streaming-programming-guide.md | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index c751dbb417..e9a27f446a 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -1948,8 +1948,8 @@ unifiedStream.print(); {% highlight python %} numStreams = 5 kafkaStreams = [KafkaUtils.createStream(...) for _ in range (numStreams)] -unifiedStream = streamingContext.union(kafkaStreams) -unifiedStream.print() +unifiedStream = streamingContext.union(*kafkaStreams) +unifiedStream.pprint() {% endhighlight %} </div> </div> |