onQueryStarted (StreamingQueryListener)

Chamado quando uma consulta é iniciada.

Sintaxe

onQueryStarted(event)

Parâmetros

Parâmetro	Tipo	Descrição
event	Evento de consulta iniciada	O objeto de evento contendo informações sobre a consulta começar.

Devoluções

None

Notas

Este método é chamado de forma síncrona com DataStreamWriter.start(). Ou seja, onQueryStarted é chamado em todos os ouvintes antes que DataStreamWriter.start() retorne o StreamingQuery correspondente. Não bloqueie este método, pois isso bloqueará sua consulta.

Exemplos

Python

from pyspark.sql.streaming import StreamingQueryListener

class MyListener(StreamingQueryListener):
    def onQueryStarted(self, event):
        print(f"Query started: {event.id}")

    def onQueryProgress(self, event):
        pass

    def onQueryIdle(self, event):
        pass

    def onQueryTerminated(self, event):
        pass

spark.streams.addListener(MyListener())