Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Wijst een naam toe aan de streamingbron voor controlepuntontwikkeling. Hierdoor kunnen streamingquery's zich ontwikkelen door bronnen opnieuw te ordenen of toe te voegen zonder de compatibiliteit van controlepunten te verbreken. Wanneer bronontwikkeling is ingeschakeld, moeten alle bronnen in een query een naam hebben.
Syntaxis
name(source_name)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
source_name |
str | De naam voor deze streamingbron. Mag alleen ASCII-letters (a-z, A-Z), cijfers (0-9) en onderstrepingstekens (_) bevatten. |
Retouren
DataStreamReader
Aantekeningen
Vereist dat streamingbronontwikkeling wordt ingeschakeld via de spark.sql.streaming.enableSourceEvolution configuratie.
Examples
Geef twee bronnen een naam en samenvoeg ze:
df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()
Geldige en ongeldige bronnamen:
# 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()