onQueryIdle (StreamingQueryListener)

Appelé lorsque la query est inactive et attend de nouvelles données à traiter.

Syntaxe

onQueryIdle(event)

parameter

parameter	Type	Description
event	QueryIdleEvent	L'objet événement contenant des informations sur la query inactive.

parameter	Type	Description
event	QueryIdleEvent	L'objet événement contenant des informations sur la query inactive.

Renvoie

None

Exemples

Python

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