onQueryStarted (StreamingQueryListener)

クエリが開始されたときに呼び出されます。

構文

onQueryStarted(event)

パラメーター

パラメーター	Type	説明
event	クエリ開始イベント	開始されたクエリに関する情報を含むイベントオブジェクト。

戻り値

None

注意

このメソッドはDataStreamWriter.start()と同期的に呼び出されます。つまり、 onQueryStarted 、 DataStreamWriter.start()対応するStreamingQueryを返す前に、すべてのリスナーで呼び出されます。このメソッドをブロックしないでください。ブロックするとクエリがブロックされます。

例

Python

from pyspark.sql.streaming import StreamingQueryListener

class MyListener(StreamingQueryListener):
    def onQueryStarted(self, event):
        print(f"Query started: {event.id}")

    def onQueryProgress(self, event):
        pass

    def onQueryIdle(self, event):
        pass

    def onQueryTerminated(self, event):
        pass

spark.streams.addListener(MyListener())