onQueryIdle （StreamingQueryListener）

当查询处于空闲状态并等待新数据进行处理时调用。

Syntax

onQueryIdle(event)

参数

退货

None

示例

from pyspark.sql.streaming import StreamingQueryListener

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

    def onQueryProgress(self, event):
        pass

    def onQueryIdle(self, event):
        print(f"Query idle: {event.id}")

    def onQueryTerminated(self, event):
        pass

spark.streams.addListener(MyListener())