Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Wacht tot een van de query's op de gekoppelde SparkSession is beëindigd sinds het maken van de context of sinds resetTerminated() deze is aangeroepen. Als een query wordt beëindigd met een uitzondering, wordt de uitzondering gegenereerd. Als timeout deze optie is ingesteld, wordt geretourneerd of een query binnen de time-out seconden is beëindigd.
Als een query al is beëindigd, worden volgende aanroepen onmiddellijk geretourneerd (indien normaal gestopt) of wordt de uitzondering onmiddellijk gegenereerd (indien beëindigd met een uitzondering). Gebruik resetTerminated() dit om eerdere beëindigingen te wissen en te wachten op nieuwe.
Syntaxis
awaitAnyTermination(timeout=None)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
timeout |
int, optioneel | Het aantal seconden dat moet worden gewacht. Als deze niet is ingesteld, wacht u voor onbepaalde tijd. |
Retouren
bool of None
Retourneert True of False is timeout ingesteld. Retourneert None als er geen time-out is ingesteld.
Examples
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()