processAllAvailable (StreamingQuery)

Blockiert, bis alle verfügbaren Daten in der Quelle verarbeitet und an die Spüle gebunden wurden. Für Tests vorgesehen.

Syntax

processAllAvailable()

Rückkehr

None

Hinweise

Im Falle der kontinuierlichen Eintreffen von Daten kann diese Methode für immer blockiert werden. Diese Methode wird nur blockiert, bis Daten, die synchron an eine Streamquelle angefügt wurden, getOffset vor dem Aufruf blockiert werden (d. a. die Ergänzung muss sofort widergespiegelt werden).

Beispiele

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