removeListener (StreamingQueryManager)

Deregisters a StreamingQueryListener.

Syntax

removeListener(listener)

Parameters

Parameter	Type	Description
listener	StreamingQueryListener	The listener to deregister.

Parameter	Type	Description
listener	StreamingQueryListener	The listener to deregister.

Returns

None

Examples

Python

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)