Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Weist der Streamingquelle einen Namen für die Prüfpunktentwicklung zu. Auf diese Weise können Streamingabfragen weiterentwickelt werden, indem Quellen neu angeordnet oder hinzugefügt werden können, ohne die Kompatibilität mit Prüfpunkten zu unterbrechen. Wenn die Quellentwicklung aktiviert ist, müssen alle Quellen in einer Abfrage benannt werden.
Syntax
name(source_name)
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
source_name |
str | Der Name für diese Streamingquelle. Darf nur ASCII-Buchstaben (a-z, A-Z), Ziffern (0-9) und Unterstriche (_) enthalten. |
Rückkehr
DataStreamReader
Hinweise
Erfordert, dass die Entwicklung der Streamingquelle über die spark.sql.streaming.enableSourceEvolution Konfiguration aktiviert wird.
Beispiele
Benennen Sie zwei Quellen, und ordnen Sie sie zu:
df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()
Gültige und ungültige Quellnamen:
# 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()