[SPARK-6328][PYTHON] Python API for StreamingListener Author: Daniel Jalova <djal...@us.ibm.com>
Closes #9186 from djalova/SPARK-6328. Project: http://git-wip-us.apache.org/repos/asf/bahir/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir/commit/502fd825 Tree: http://git-wip-us.apache.org/repos/asf/bahir/tree/502fd825 Diff: http://git-wip-us.apache.org/repos/asf/bahir/diff/502fd825 Branch: refs/heads/master Commit: 502fd8257d60393e8a2d5596feee95d02abd6f75 Parents: 3b1cc91 Author: Daniel Jalova <djal...@us.ibm.com> Authored: Mon Nov 16 11:29:27 2015 -0800 Committer: Tathagata Das <tathagata.das1...@gmail.com> Committed: Mon Nov 16 11:29:27 2015 -0800 ---------------------------------------------------------------------- streaming-mqtt/python/__init__.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir/blob/502fd825/streaming-mqtt/python/__init__.py ---------------------------------------------------------------------- diff --git a/streaming-mqtt/python/__init__.py b/streaming-mqtt/python/__init__.py index d2644a1..66e8f8e 100644 --- a/streaming-mqtt/python/__init__.py +++ b/streaming-mqtt/python/__init__.py @@ -17,5 +17,6 @@ from pyspark.streaming.context import StreamingContext from pyspark.streaming.dstream import DStream +from pyspark.streaming.listener import StreamingListener -__all__ = ['StreamingContext', 'DStream'] +__all__ = ['StreamingContext', 'DStream', 'StreamingListener']
