Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Wartet auf die Beendigung dieser Abfrage, entweder nach stop() oder nach einer Ausnahme. Wenn die Abfrage mit einer Ausnahme beendet wurde, wird die Ausnahme ausgelöst. Wenn timeout dieser Wert festgelegt ist, wird zurückgegeben, ob die Abfrage innerhalb der Timeout-Sekunden beendet wurde.
Wenn die Abfrage bereits beendet wurde, werden nachfolgende Aufrufe entweder sofort zurückgegeben (wenn sie normal beendet werden), oder die Ausnahme sofort auslösen (wenn sie mit einer Ausnahme beendet wird).
Syntax
awaitTermination(timeout=None)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
timeout |
int, optional | Die Anzahl der Sekunden, die gewartet werden sollen. Wenn sie nicht festgelegt ist, wartet sie auf unbestimmte Zeit. |
Rückkehr
bool oder None
Gibt zurück True oder False wenn timeout festgelegt, gibt an, ob die Abfrage innerhalb des Timeouts beendet wurde. Gibt zurück None , wenn kein Timeout festgelegt ist.
Beispiele
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()