onQueryTerminated (StreamingQueryListener)

Chamado quando uma consulta é interrompida, com ou sem erro.

Sintaxe

onQueryTerminated(event)

Parâmetros

Parâmetro	Tipo	Descrição
event	Evento de consulta encerrada	O objeto de evento que contém informações sobre a consulta encerrada.

Devoluções

None

Exemplos

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