Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Attend que l’une des requêtes sur l’associé SparkSession se termine depuis la création du contexte, ou depuis resetTerminated() son appel. Si une requête s’est terminée avec une exception, l’exception est levée. Si timeout elle est définie, retourne si une requête s’est terminée dans le délai d’expiration des secondes.
Si une requête est déjà terminée, les appels suivants retournent immédiatement (s’ils sont arrêtés normalement) ou lèvent immédiatement l’exception (si terminée avec une exception). Permet resetTerminated() d’effacer les arrêts passés et d’attendre les nouveaux.
Syntaxe
awaitAnyTermination(timeout=None)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
timeout |
int, facultatif | Nombre de secondes à attendre. S’il n’est pas défini, attend indéfiniment. |
Retours
bool ou None
Cette propriété renvoie True ou False si timeout elle est définie. Retourne None si aucun délai d’attente n’est défini.
Exemples
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()