onQueryProgress (StreamingQueryListener)

何らかのステータス更新（摂取速度の更新など）があった場合に呼び出されます。

構文

onQueryProgress(event)

パラメーター

パラメーター	Type	説明
event	クエリ進行状況イベント	クエリの進行状況情報を含むイベントオブジェクト。

戻り値

None

注意

このメソッドは非同期です。StreamingQueryのステータスは、このメソッドがいつ呼び出されても常に最新の状態になります。したがって、 StreamingQueryの状態は、イベントを処理する前または処理中に変更される可能性があります。例えば、 QueryProgressEventを処理しているときにStreamingQueryが終了する場合があります。

例

Python

from pyspark.sql.streaming import StreamingQueryListener

class MyListener(StreamingQueryListener):
    def onQueryStarted(self, event):
        pass

    def onQueryProgress(self, event):
        print(f"Query progress: {event.progress.numInputRows} rows processed")

    def onQueryIdle(self, event):
        pass

    def onQueryTerminated(self, event):
        pass

spark.streams.addListener(MyListener())