onQueryTerminated (StreamingQueryListener)

Appelée lorsqu'une query est arrêtée, avec ou sans erreur.

Syntaxe

onQueryTerminated(event)

parameter

parameter	Type	Description
event	QueryTerminatedEvent	L'objet d'événement contenant des informations sur la query terminée.

parameter	Type	Description
event	QueryTerminatedEvent	L'objet d'événement contenant des informations sur la query terminée.

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):
        pass

    def onQueryTerminated(self, event):
        print(f"Query terminated: {event.id}")

spark.streams.addListener(MyListener())