You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bahir.apache.org by lr...@apache.org on 2016/06/10 15:23:49 UTC
[10/50] [abbrv] bahir git commit: [SPARK-6328][PYTHON] Python API for
StreamingListener
[SPARK-6328][PYTHON] Python API for StreamingListener
Author: Daniel Jalova <dj...@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 <dj...@us.ibm.com>
Authored: Mon Nov 16 11:29:27 2015 -0800
Committer: Tathagata Das <ta...@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']