processAllAvailable (StreamingQuery)

Blokkeert totdat alle beschikbare gegevens in de bron zijn verwerkt en doorgevoerd in de sink. Bedoeld voor testen.

Syntaxis

processAllAvailable()

Retouren

None

Aantekeningen

In het geval van voortdurend binnenkomende gegevens, kan deze methode voor altijd blokkeren. Deze methode wordt alleen gegarandeerd geblokkeerd totdat gegevens die synchroon aan een stroombron zijn toegevoegd voorafgaand aan aan aanroep (dat wil gezegd, getOffset moeten onmiddellijk overeenkomen met de toevoeging).

Examples

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