Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Attende la chiusura della query, da stop() o da un'eccezione. Se la query ha terminato con un'eccezione, verrà generata l'eccezione. Se timeout è impostato, restituisce se la query è stata terminata entro i secondi di timeout.
Se la query è già stata terminata, le chiamate successive restituiscono immediatamente (se arrestate normalmente) o generano immediatamente l'eccezione (se terminata con un'eccezione).
Sintassi
awaitTermination(timeout=None)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
timeout |
int, facoltativo | Numero di secondi di attesa. Se non è impostato, attende per un periodo illimitato. |
Restituzioni
bool oppure None
Restituisce True o False se timeout è impostato, che indica se la query è stata terminata entro il timeout. Restituisce None se non è impostato alcun timeout.
Examples
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()