addListener (StreamingQueryManager)

ストリーミング クエリのライフサイクル イベント コールバックを受信するには、 StreamingQueryListenerを登録します。

構文

addListener(listener)

パラメーター

パラメーター	Type	説明
listener	ストリーミングクエリリスナー	リスナーを登録する。

戻り値

None

注意

Spark Connectモードでは、提供されたリスナーは、その外部で定義された変数にアクセスできません。Connectモードでリスナー内のセッションにアクセスするには、 sparkの代わりにself.spark使用してください。

例

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)