addListener (StreamingQueryManager)

Enregistre un StreamingQueryListener pour recevoir les rappels d'événements de cycle de vie pour les query en streaming.

Syntaxe

addListener(listener)

parameter

parameter	Type	Description
listener	StreamingQueryListener	L'écouteur à enregistrer.

parameter	Type	Description
listener	StreamingQueryListener	L'écouteur à enregistrer.

Renvoie

None

Notes

En mode Spark Connect, l'écouteur fourni n'a pas accès aux variables définies en dehors de celui-ci. Utilisez self.spark au lieu de spark pour accéder à la session dans l'écouteur en mode Connect.

Exemples

Python

from pyspark.sql.streaming import StreamingQueryListener

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

    def onQueryProgress(self, event):
        pass

    def onQueryIdle(self, event):
        pass

    def onQueryTerminated(self, event):
        pass

test_listener = TestListener()
spark.streams.addListener(test_listener)
spark.streams.removeListener(test_listener)