onQueryIdle (StreamingQueryListener)

Chamado quando a consulta está parada e aguardando novos dados para processar.

Sintaxe

onQueryIdle(event)

Parâmetros

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

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

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):
        print(f"Query idle: {event.id}")

    def onQueryTerminated(self, event):
        pass

spark.streams.addListener(MyListener())