awaitAnyTermination (StreamingQueryManager)

Čeká na ukončení některého z dotazů na přidruženém objektu SparkSession od vytvoření kontextu nebo od resetTerminated() jeho zavolání. Pokud se některý dotaz ukončil s výjimkou, vyvolá se výjimka. Pokud timeout je nastavená hodnota, vrátí, jestli se některý dotaz ukončil během sekund č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). Slouží resetTerminated() k vymazání minulých ukončení a čekání na nové.

Syntaxe

awaitAnyTermination(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 hodnotu nebo False je-li timeout nastavena. Vrátí None , pokud není nastavený žádný časový limit.

Příklady

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
spark.streams.awaitAnyTermination(5)
# True
sq.stop()