Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
Asigna un nombre al origen de streaming para la evolución del punto de control. Esto permite que las consultas de streaming evolucionen al permitir que los orígenes se reordenen o agreguen sin interrumpir la compatibilidad con los puntos de control. Cuando la evolución del origen está habilitada, todos los orígenes de una consulta deben denominarse.
Sintaxis
name(source_name)
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
source_name |
str | Nombre de este origen de streaming. Debe contener solo letras ASCII (a-z, A-Z), dígitos (0-9) y caracteres de subrayado (_). |
Devoluciones
DataStreamReader
Notas
Requiere que la evolución del origen de streaming esté habilitada a través de la spark.sql.streaming.enableSourceEvolution configuración.
Ejemplos
Asigne un nombre a dos orígenes y adíguelos:
df1 = spark.readStream.format("rate").name("source1").load()
df2 = spark.readStream.format("rate").name("source2").load()
query = df1.union(df2).writeStream.format("console").start()
Nombres de origen válidos y no válidos:
# 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()