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 op de beëindiging van deze query, hetzij met stop() of met een uitzondering. Als de query is beëindigd met een uitzondering, wordt de uitzondering gegenereerd. Als timeout deze optie is ingesteld, wordt geretourneerd of de query binnen de time-out seconden is beëindigd.
Als de query al is beëindigd, worden volgende aanroepen onmiddellijk geretourneerd (als deze normaal is gestopt) of genereert u de uitzondering onmiddellijk (indien beëindigd met een uitzondering).
Syntaxis
awaitTermination(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 als timeout deze is ingesteld, waarmee wordt aangegeven of de query binnen de time-out is beëindigd. Retourneert None als er geen time-out is ingesteld.
Examples
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()