awaitTermination (StreamingQuery)

Özel durum tarafından veya özel durum tarafından bu sorgunun stop() sonlandırılmasına yönelik bekler. Sorgu bir özel durumla sonlandırıldıysa, özel durum oluşturulur. ayarlanırsa timeout , sorgunun zaman aşımı saniyeleri içinde sonlandırılıp sonlandırılmadığını döndürür.

Sorgu zaten sonlandırıldıysa, izleyen çağrılar hemen geri döner (normal şekilde durdurulursa) veya özel durumu hemen oluşturur (bir özel durumla sonlandırıldıysa).

Sözdizimi

awaitTermination(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

Sorgunun zaman aşımı içinde sonlandırılıp sonlandırılmadığını belirten veya True ayarlanırsa 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('query_awaitTermination').start()
sq.awaitTermination(5)
# False
sq.stop()