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 /mllib | |
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 'mllib')
0 files changed, 0 insertions, 0 deletions