Bryan Cutler a2016b4bc4 [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		2015-06-19 00:07:53 -07:00
..
__init__.py	[SPARK-2377] Python API for Streaming	2014-10-12 02:46:56 -07:00
context.py	[SPARK-6949] [SQL] [PySpark] Support Date/Timestamp in Column expression	2015-04-21 00:08:18 -07:00
dstream.py	[SPARK-8444] [STREAMING] Adding Python streaming example for queueStream	2015-06-19 00:07:53 -07:00
kafka.py	[SPARK-6657] [PYSPARK] Fix doc warnings	2015-05-18 08:35:14 -07:00
tests.py	[SPARK-2808] [STREAMING] [KAFKA] cleanup tests from	2015-06-07 21:42:45 +01:00
util.py	[SPARK-4897] [PySpark] Python 3 support	2015-04-16 16:20:57 -07:00