removeListener （StreamingQueryManager）

取消注册 .StreamingQueryListener

Syntax

removeListener(listener)

参数

参数 类型 Description
listener StreamingQueryListener 要取消注册的侦听器。

退货

None

示例

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)
  • Last updated on