aboutsummaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authorchriskang90 <jckang@uchicago.edu>2015-11-09 19:39:22 +0100
committerSean Owen <sowen@cloudera.com>2015-11-09 19:39:22 +0100
commit874cd66d4b6d156d0ef112a3d0f3bc5683c6a0ec (patch)
treeaa69cafe960a8a3a8b55cfecafd625b94db89736 /docs
parentcd174882a5a211298d6e173fe989d567d08ebc0d (diff)
downloadspark-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.
Diffstat (limited to 'docs')
-rw-r--r--docs/streaming-programming-guide.md4
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>