awaitTermination (StreamingQuery)

Čeká na ukončení tohoto dotazu, a to buď výjimkou stop() , nebo výjimkou. Pokud se dotaz ukončil s výjimkou, vyvolá se výjimka. Pokud timeout je nastavená hodnota, vrátí dotaz, zda se dotaz ukončil v sekundách časového limitu.

Pokud už dotaz skončil, následné volání se vrátí okamžitě (pokud je normálně zastaveno) nebo vyvolá výjimku okamžitě (pokud je ukončena výjimkou).

Syntaxe

awaitTermination(timeout=None)

Parametry

Parameter	Typ	Description
timeout	int, volitelné	Počet sekund, které se mají počkat. Pokud není nastavená, počká na neomezenou dobu.

Návraty

bool nebo None

Vrátí True nebo False pokud timeout je nastavená hodnota označující, jestli se dotaz ukončil v rámci časového limitu. Vrátí None , pokud není nastavený žádný časový limit.

Příklady

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()