onQueryProgress (StreamingQueryListener)

Chamado quando há alguma atualização de status (taxa de ingestão atualizada, etc.).

Sintaxe

onQueryProgress(event)

Parâmetros

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

Devoluções

None

Notas

Este método é assíncrono. O status em StreamingQuery será sempre o mais recente, independentemente de quando este método for chamado. Portanto, o status de StreamingQuery pode ser alterado antes ou durante o processamento do evento. Por exemplo, você pode descobrir que StreamingQuery é encerrado quando você está processando QueryProgressEvent.

Exemplos

Python

from pyspark.sql.streaming import StreamingQueryListener

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

    def onQueryProgress(self, event):
        print(f"Query progress: {event.progress.numInputRows} rows processed")

    def onQueryIdle(self, event):
        pass

    def onQueryTerminated(self, event):
        pass

spark.streams.addListener(MyListener())