Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Tilldelar ett namn till strömningskällan för kontrollpunktsutveckling. Detta gör att strömmande frågor kan utvecklas genom att göra så att källor ordnas om eller läggs till utan att kontrollpunktskompatibiliteten bryts. När källutvecklingen är aktiverad måste alla källor i en fråga namnges.
Syntax
name(source_name)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
source_name |
str | Namnet på den här strömmande källan. Får endast innehålla ASCII-bokstäver (a-z, A-Z), siffror (0-9) och understreck (_). |
Retur
DataStreamReader
Notes
Kräver att strömningskällans utveckling aktiveras via konfigurationen spark.sql.streaming.enableSourceEvolution .
Exempel
Namnge två källor och förena dem:
df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()
Giltiga och ogiltiga källnamn:
# 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()