Note
Access to this page requires authorization. You can try signing in or changing directories.
Access to this page requires authorization. You can try changing directories.
Deregisters a StreamingQueryListener.
Syntax
removeListener(listener)
Parameters
| Parameter | Type | Description |
|---|---|---|
listener |
StreamingQueryListener | The listener to deregister. |
Returns
None
Examples
from pyspark.sql.streaming import StreamingQueryListener
class TestListener(StreamingQueryListener):
def onQueryStarted(self, event):
pass
def onQueryProgress(self, event):
pass
def onQueryIdle(self, event):
pass
def onQueryTerminated(self, event):
pass
test_listener = TestListener()
spark.streams.addListener(test_listener)
spark.streams.removeListener(test_listener)