StreamingQuery

Yeni veriler geldikçe arka planda sürekli olarak yürütülen bir sorgu tanıtıcısı. Tüm yöntemler iş parçacığı açısından güvenlidir.

Sözdizimi

# Returned by DataStreamWriter.start() or DataStreamWriter.toTable()
q = df.writeStream.format("console").start()

Özellikler

Mülkiyet Açıklama
id Bu sorgunun denetim noktası verilerinden yeniden başlatmalar arasında kalıcı olan benzersiz kimliğini döndürür.
runId Bu sorgunun yeniden başlatmalar arasında kalıcı olmayan benzersiz kimliğini döndürür.
name Sorgunun kullanıcı tarafından belirtilen adını veya None belirtilmemişse döndürür.
isActive Bu akış sorgusu şu anda etkin olup olmadığını döndürür.
status Sorgunun geçerli durumunu bir dikte olarak döndürür.
recentProgress Bu sorgu için en son StreamingQueryProgress güncelleştirmelerden oluşan bir dizi döndürür.
lastProgress En son StreamingQueryProgress güncelleştirmeyi veya None güncelleştirme yapılmadıysa döndürür.

Methods

Yöntem Açıklama
awaitTermination(timeout) Özel durum tarafından veya özel durum tarafından bu sorgunun stop() sonlandırılmasına yönelik bekler.
processAllAvailable() Kaynaktaki tüm kullanılabilir veriler işlenip havuza işlenene kadar engeller. Test için tasarlanmıştır.
stop() Bu akış sorgusunu durdurur.
explain(extended) Hata ayıklama için (mantıksal ve fiziksel) planları konsola yazdırır.
exception() StreamingQueryException Sorgu bir özel durumla sonlandırıldıysa veya Nonedöndürür.

Örnekler

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