diff options
| author | Bryan Cutler <bjcutler@us.ibm.com> | 2015-06-19 00:07:53 -0700 |
|---|---|---|
| committer | Davies Liu <davies@databricks.com> | 2015-06-19 00:07:53 -0700 |
| commit | a2016b4bc4ef13339f168c3f4e135fa422046137 (patch) | |
| tree | fc3e275a8e2c3d7738d73be70d81680f2b05d0bf /python/pyspark/streaming/dstream.py | |
| parent | 754929b153aba3a8f8fbafa1581957da4ccc18be (diff) | |
| download | spark-a2016b4bc4ef13339f168c3f4e135fa422046137.tar.gz spark-a2016b4bc4ef13339f168c3f4e135fa422046137.tar.bz2 spark-a2016b4bc4ef13339f168c3f4e135fa422046137.zip | |
[SPARK-8444] [STREAMING] Adding Python streaming example for queueStream
A Python example similar to the existing one for Scala.
Author: Bryan Cutler <bjcutler@us.ibm.com>
Closes #6884 from BryanCutler/streaming-queueStream-example-8444 and squashes the following commits:
435ba7e [Bryan Cutler] [SPARK-8444] Fixed style checks, increased sleep time to show empty queue
257abb0 [Bryan Cutler] [SPARK-8444] Stop context gracefully, Removed unused import, Added description comment
376ef6e [Bryan Cutler] [SPARK-8444] Fixed bug causing DStream.pprint to append empty parenthesis to output instead of blank line
1ff5f8b [Bryan Cutler] [SPARK-8444] Adding Python streaming example for queue_stream
Diffstat (limited to 'python/pyspark/streaming/dstream.py')
| -rw-r--r-- | python/pyspark/streaming/dstream.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/streaming/dstream.py b/python/pyspark/streaming/dstream.py index ff097985fa..8dcb9645cd 100644 --- a/python/pyspark/streaming/dstream.py +++ b/python/pyspark/streaming/dstream.py @@ -176,7 +176,7 @@ class DStream(object): print(record) if len(taken) > num: print("...") - print() + print("") self.foreachRDD(takeAndPrint) |