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 l’arrêt de cette requête, soit par stop() une exception. Si la requête s’est terminée avec une exception, l’exception est levée. Si timeout elle est définie, retourne si la requête s’est terminée dans le délai d’expiration des secondes.
Si la requête s’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 (en cas d’arrêt avec une exception).
Syntaxe
awaitTermination(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, indiquant si la requête s’est terminée dans le délai d’expiration. 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('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()