name (DataStreamReader)

Присваивает имя источнику потоковой передачи для эволюции контрольных точек. Это позволяет потоковым запросам развиваться, позволяя источникам изменять порядок или добавлять их без критической совместимости контрольных точек. При включении эволюции источника все источники в запросе должны быть названы.

Синтаксис

name(source_name)

Параметры

Параметр	Тип	Описание
source_name	str	Имя этого источника потоковой передачи. Должен содержать только буквы ASCII (a-z, A-Z), цифры (0-9) и символы подчеркивания (_).

Возвраты

DataStreamReader

Примечания

Требуется включить эволюцию источника потоковой передачи с помощью spark.sql.streaming.enableSourceEvolution конфигурации.

Примеры

Назовите два источника и объедините их:

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

Допустимые и недопустимые имена источников:

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