StreamingQueryManager

ile StreamingQueryilişkili tüm etkin SparkSession örnekleri yönetir. Buna erişmek için kullanın spark.streams .

Sözdizimi

# Access through SparkSession
spark.streams

Özellikler

Mülkiyet	Açıklama
active	Bu SparkSessionile ilişkili tüm etkin akış sorgularının listesini döndürür.

Methods

Yöntem	Açıklama
get(id)	Benzersiz kimliğine göre etkin bir sorgu döndürür.
awaitAnyTermination(timeout)	Etkin sorgu sonlandırılıncaya kadar veya zaman aşımı süresi dolana kadar bekler.
resetTerminated()	Yeni sonlandırmaları beklemek için yeniden kullanılabilmesi için sonlandırılmış sorguları awaitAnyTermination() unutur.
addListener(listener)	Yaşam döngüsü olay geri çağırmalarını almak için bir StreamingQueryListener kaydeder.
removeListener(listener)	bir kaydının kaydını kaldırıyor StreamingQueryListener.

Örnekler

sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sqm = spark.streams
[q.name for q in sqm.active]
# ['this_query']
sqm.awaitAnyTermination(5)
# True
sq.stop()
sqm.resetTerminated()