name (DataStreamReader)

Atribui um nome à fonte de streaming para a evolução do ponto de verificação. Isso permite que as consultas de streaming evoluam permitindo que as fontes sejam reordenadas ou adicionadas sem interromper a compatibilidade do ponto de verificação. Quando a evolução da origem está habilitada, todas as fontes em uma consulta devem ser nomeadas.

Sintaxe

name(source_name)

Parâmetros

Devoluções

DataStreamReader

Observações

Requer que a evolução da fonte de streaming seja habilitada por meio da spark.sql.streaming.enableSourceEvolution configuração.

Exemplos

Nomeie duas fontes e as unione:

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

Nomes de origem válidos e invá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()