aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/streaming/__init__.py')
-rw-r--r--python/pyspark/streaming/__init__.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/python/pyspark/streaming/__init__.py b/python/pyspark/streaming/__init__.py
index d2644a1d4f..66e8f8ef00 100644
--- a/python/pyspark/streaming/__init__.py
+++ b/python/pyspark/streaming/__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']