processarTodosDisponíveis (StreamingQuery)

Bloqueia até que todos os dados disponíveis na origem tenham sido processados e enviados para o destino. Destinado a testes.

Sintaxe

processAllAvailable()

Devoluções

None

Notas

No caso de recebimento contínuo de dados, esse método pode bloquear indefinidamente. Este método só tem garantia de bloqueio até que os dados tenham sido adicionados de forma síncrona a uma fonte de transmissão antes da invocação (ou seja, getOffset deve refletir imediatamente a adição).

Exemplos

Python

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq.processAllAvailable()
sq.stop()