awaitTermination (StreamingQuery)

Attend la fin de cette query, soit par stop(), soit par une exception. Si la query s'est terminée par une exception, l'exception sera levée. Si timeout est défini, indique si la query s'est terminée dans le délai imparti en secondes.

Si la query est déjà terminée, les appels ultérieurs reviennent immédiatement (si elle est arrêtée normalement) ou lèvent immédiatement l'exception (si elle est terminée avec une exception).

Syntaxe

awaitTermination(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

Renvoie True ou False si timeout est défini, indiquant si la requête s'est terminée dans le délai imparti. 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('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()