Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181630426
--- Diff: python/pyspark/streaming/listener.py ---
@@ -22,6 +22,10 @@ class StreamingListener(object):
def __init__(self):
pass
+
+ def onStreamingStarted(self, streamingStarted):
--- End diff --
this isnt doc only change then, I think?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]