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.
Denetim noktası evrimi için akış kaynağına bir ad atar. Bu, kaynakların yeniden sıralanması veya denetim noktası uyumluluğunu bozmadan eklenmesini sağlayarak akış sorgularının gelişmesine olanak tanır. Kaynak geliştirme etkinleştirildiğinde, sorgudaki tüm kaynaklar adlandırılmalıdır.
Sözdizimi
name(source_name)
Parametreler
| Parametre | Türü | Açıklama |
|---|---|---|
source_name |
str | Bu akış kaynağının adı. Yalnızca ASCII harfler (a-z, A-Z), basamaklar (0-9) ve alt çizgi (_) içermelidir. |
İadeler
DataStreamReader
Notlar
Akış kaynağı evriminin yapılandırma aracılığıyla etkinleştirilmesini spark.sql.streaming.enableSourceEvolution gerektirir.
Örnekler
İki kaynağı adlandırıp birleşimlerini sağlayın:
df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()
Geçerli ve geçersiz kaynak adları:
# Valid names
spark.readStream.format("rate").name("mySource").load()
spark.readStream.format("rate").name("my_source_123").load()
# Invalid name — raises AnalysisException
spark.readStream.format("rate").name("my-source").load()