processAllAvailable (StreamingQuery)

Blocos até que todos os dados disponíveis na fonte tenham sido processados e comprometidos no sumidouro. Destinado a testes.

Sintaxe

processAllAvailable()

Devoluções

None

Notes

No caso de dados que chegam continuamente, este método pode bloquear para sempre. Este método só garante bloquear até que os dados que tenham sido adicionados síncronicamente 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()