onQueryStarted （StreamingQueryListener）

启动查询时调用。

Syntax

onQueryStarted(event)

参数

退货

None

注释

此方法与 DataStreamWriter.start().. 也就是说，在返回相应的onQueryStarted侦听器之前DataStreamWriter.start()对所有StreamingQuery侦听器调用。 不要阻止此方法，因为它会阻止查询。

示例

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())