processAllAvailable (StreamingQuery)

Bloqueia até que todos os dados disponíveis na fonte sejam processados e confirmados no coletor. Indicado para teste.

Sintaxe

processAllAvailable()

Devoluções

None

Observações

No caso de dados de chegada contínua, esse método pode ser bloqueado para sempre. Esse método só tem a garantia de bloquear até que os dados que foram acrescentados de forma síncrona a uma fonte de fluxo antes da invocação (ou seja, getOffset devem refletir imediatamente a adição).

Exemplos

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