Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Väntar på att den här frågan ska avslutas, antingen av stop() eller med ett undantag. Om frågan har avslutats med ett undantag genereras undantaget. Om timeout har angetts returneras om frågan har avslutats inom tidsgränsens sekunder.
Om frågan redan har avslutats returnerar efterföljande anrop antingen omedelbart (om de stoppas normalt) eller utlöser undantaget omedelbart (om det avslutas med ett undantag).
Syntax
awaitTermination(timeout=None)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
timeout |
int, valfritt | Antal sekunder att vänta. Om den inte har angetts väntar du på obestämd tid. |
Retur
bool eller None
Returnerar True eller False om timeout har angetts, vilket anger om frågan avslutades inom tidsgränsen. Returnerar None om ingen tidsgräns har angetts.
Exempel
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()