addListener （StreamingQueryManager）

注册用于 StreamingQueryListener 接收流式处理查询的生命周期事件回调。

Syntax

addListener(listener)

参数

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

退货

None

注释

在 Spark Connect 模式下，提供的侦听器无权访问其外部定义的变量。 使用 self.spark 而不是 spark 在 Connect 模式下访问侦听器中的会话。

示例

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