Liang-Chi Hsieh 8bb0df2c65 [SPARK-24014][PYSPARK] Add onStreamingStarted method to StreamingListener ... ## What changes were proposed in this pull request? The `StreamingListener` in PySpark side seems to be lack of `onStreamingStarted` method. This patch adds it and a test for it. This patch also includes a trivial doc improvement for `createDirectStream`. Original PR is #21057. ## How was this patch tested? Added test. Author: Liang-Chi Hsieh <viirya@gmail.com> Closes #21098 from viirya/SPARK-24014.		2018-04-19 10:00:57 +08:00
..
__init__.py	[SPARK-6328][PYTHON] Python API for StreamingListener	2015-11-16 11:29:27 -08:00
context.py	[SPARK-18447][DOCS] Fix the markdown for Note:/NOTE:/Note that across Python API documentation	2016-11-22 11:40:18 +00:00
dstream.py	[MINOR] Fix Typos 'an -> a'	2016-06-06 09:35:47 +01:00
flume.py	[SPARK-22313][PYTHON][FOLLOWUP] Explicitly import warnings namespace in flume.py	2017-12-29 14:46:03 +09:00
kafka.py	[SPARK-24014][PYSPARK] Add onStreamingStarted method to StreamingListener	2018-04-19 10:00:57 +08:00
kinesis.py	[SPARK-19405][STREAMING] Support for cross-account Kinesis reads via STS	2017-02-22 11:32:36 -05:00
listener.py	[SPARK-24014][PYSPARK] Add onStreamingStarted method to StreamingListener	2018-04-19 10:00:57 +08:00
tests.py	[SPARK-24014][PYSPARK] Add onStreamingStarted method to StreamingListener	2018-04-19 10:00:57 +08:00
util.py	[SPARK-23522][PYTHON] always use sys.exit over builtin exit	2018-03-08 20:38:34 +09:00