processAllAvailable (StreamingQuery)

Bloque jusqu’à ce que toutes les données disponibles dans la source soient traitées et validées sur le récepteur. Conçu pour les tests.

Syntaxe

processAllAvailable()

Retours

None

Remarques

En cas d’arrivée continue de données, cette méthode peut bloquer à jamais. Cette méthode est garantie uniquement pour bloquer jusqu’à ce que les données qui ont été ajoutées de manière synchrone à une source de flux avant l’appel (autrement dit, getOffset doivent immédiatement refléter l’ajout).

Exemples

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