name (DataStreamReader)

Przypisuje nazwę do źródła przesyłania strumieniowego na potrzeby ewolucji punktów kontrolnych. Dzięki temu zapytania przesyłane strumieniowo mogą ewoluować, umożliwiając zmianę kolejności lub dodanie źródeł bez niezgodności punktu kontrolnego. Po włączeniu ewolucji źródła wszystkie źródła w zapytaniu muszą mieć nazwę .

Składnia

name(source_name)

Parametry

Parameter	Typ	Opis
source_name	str	Nazwa tego źródła przesyłania strumieniowego. Musi zawierać tylko litery ASCII (a-z, A-Z), cyfry (0–9) i podkreślenia (_).

Zwroty

DataStreamReader

Notatki

Wymaga włączenia ewolucji źródła przesyłania strumieniowego spark.sql.streaming.enableSourceEvolution za pośrednictwem konfiguracji.

Examples

Nazwij dwa źródła i ujmij je:

df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()

Prawidłowe i nieprawidłowe nazwy źródłowe:

# 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()