Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/21098#discussion_r182440791
--- Diff: python/pyspark/streaming/listener.py ---
@@ -23,6 +23,12 @@ class StreamingListener(object):
def __init__(self):
pass
+ def onStreamingStarted(self, streamingStarted):
--- End diff --
Because `PythonStreamingListener` have such method, I think it is still
better to add it here. And I also add a test to make sure it works.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
