awaitAnyTermination (StreamingQueryManager)

Attend que l'une des queries sur le SparkSession associé se soit terminée depuis la création du contexte, ou depuis l'appel de resetTerminated(). Si une query s'est terminée avec une exception, celle-ci sera levée. Si timeout est défini, indique si une query s'est terminée dans le délai d'expiration imparti.

Si une query a déjà été terminée, les appels ultérieurs renvoient immédiatement (si elle est arrêtée normalement) ou lèvent l’exception immédiatement (si elle est terminée avec une exception). Utilisez resetTerminated() pour effacer les arrêts précédents et attendre les nouveaux.

Syntaxe

awaitAnyTermination(timeout=None)

parameter

parameter	Type	Description
timeout	int, facultatif	Le nombre de secondes à attendre. S'il n'est pas défini, il attend indéfiniment.

parameter	Type	Description
timeout	int, facultatif	Le nombre de secondes à attendre. S'il n'est pas défini, il attend indéfiniment.

Renvoie

bool OU None

Retourne True ou False si timeout est défini. Retourne None si aucun délai d'expiration n'est défini.

Exemples

Python

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()