awaitAnyTermination (StreamingQueryManager)

bağlamın oluşturulmasından veya çağrıldığından beri SparkSession ilişkili resetTerminated() sorgulardaki sorgulardan herhangi birinin sonlandırılmasını bekler. Herhangi bir sorgu özel durumla sonlandırıldıysa, özel durum oluşturulur. ayarlanırsa timeout , zaman aşımı saniyeleri içinde herhangi bir sorgunun sonlandırılıp sonlandırılmadığını döndürür.

Bir sorgu zaten sonlandırıldıysa, izleyen çağrılar hemen döndürür (normal şekilde durdurulursa) veya özel durumu hemen oluşturur (bir özel durumla sonlandırıldıysa). Geçmiş sonlandırmaları temizlemek ve yenilerini beklemek için kullanın resetTerminated() .

Sözdizimi

awaitAnyTermination(timeout=None)

Parametreler

Parametre	Türü	Açıklama
timeout	int, isteğe bağlı	Beklenecek saniye sayısı. Ayarlanmamışsa süresiz olarak bekler.

İadeler

bool veya None

veya True ayarlandıysa False döndürürtimeout. Zaman aşımı ayarlı değilse döndürür None .

Örnekler

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