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 tills någon av frågorna på den associerade SparkSession har avslutats sedan kontexten skapades eller sedan resetTerminated() anropades. Om en fråga avslutas med ett undantag utlöses undantaget. Om timeout har angetts returneras om någon fråga har avslutats inom tidsgränsens sekunder.
Om en fråga redan har avslutats returnerar efterföljande anrop antingen omedelbart (om de stoppas normalt) eller utlöser undantaget omedelbart (om det avslutas med ett undantag). Använd resetTerminated() för att rensa tidigare avslutningar och vänta på nya.
Syntax
awaitAnyTermination(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. Returnerar None om ingen tidsgräns har angetts.
Exempel
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()