processAllAvailable (StreamingQuery)

Blockerar tills alla tillgängliga data i källan har bearbetats och checkats in till mottagaren. Avsedd för testning.

Syntax

processAllAvailable()

Retur

None

Notes

När det gäller kontinuerligt ankommande data kan den här metoden blockeras för alltid. Den här metoden är bara garanterad att blockeras tills data som har lagts till synkront till en dataströmkälla före anropet (det vill getOffset sa måste omedelbart återspegla tillägget).

Exempel

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