adicionarListener (Gerenciador de Consultas de Streaming)

registre-se em StreamingQueryListener para receber retornos de chamada de eventos de ciclo de vida para consultas de transmissão.

Sintaxe

addListener(listener)

Parâmetros

Parâmetro	Tipo	Descrição
listener	Ouvinte de consulta de streaming	O ouvinte para registro.

Devoluções

None

Notas

No modo Spark Connect, o listener fornecido não tem acesso a variáveis definidas fora dele. Use self.spark em vez de spark para acessar a sessão dentro do ouvinte no modo Connect.

Exemplos

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)