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, bis eine der Abfragen für das zugeordnete SparkSession Ereignis seit der Erstellung des Kontexts oder seit resetTerminated() dem Aufruf beendet wurde. Wenn eine Abfrage mit ausnahme beendet wurde, wird die Ausnahme ausgelöst. Wenn timeout dieser Wert festgelegt ist, wird zurückgegeben, ob eine Abfrage innerhalb der Timeout-Sekunden beendet wurde.
Wenn eine 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). Verwenden Sie diese Einstellung resetTerminated() , um frühere Kündigungen zu löschen und auf neue zu warten.
Syntax
awaitAnyTermination(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 ist timeout festgelegt. Gibt zurück None , wenn kein Timeout festgelegt ist.
Beispiele
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()