Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Assegna un nome all'origine di streaming per l'evoluzione del checkpoint. In questo modo, le query di streaming possono evolversi consentendo di riordinare o aggiungere origini senza interrompere la compatibilità dei checkpoint. Quando l'evoluzione dell'origine è abilitata, tutte le origini in una query devono essere denominate.
Sintassi
name(source_name)
Parametri
| Parametro | Tipo | Descrizione |
|---|---|---|
source_name |
str | Nome dell'origine di streaming. Deve contenere solo lettere ASCII (a-z, A-Z), cifre (0-9) e caratteri di sottolineatura (_). |
Restituzioni
DataStreamReader
Note
Richiede l'abilitazione dell'evoluzione dell'origine di streaming tramite la spark.sql.streaming.enableSourceEvolution configurazione.
Examples
Assegnare un nome a due origini e unirle:
df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()
Nomi di origine validi e non validi:
# 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()