Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
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