name (DataStreamReader)

Přiřadí zdroji streamování název pro vývoj kontrolních bodů. To umožňuje vývoj streamovaných dotazů tím, že umožňuje měnit pořadí nebo přidávat zdroje bez narušení kompatibility kontrolních bodů. Pokud je povolen vývoj zdroje, musí být všechny zdroje v dotazu pojmenovány.

Syntaxe

name(source_name)

Parametry

Parameter	Typ	Description
source_name	str	Název tohoto zdroje streamování. Musí obsahovat pouze písmena ASCII (a-z, A-Z), číslice (0–9) a podtržítka (_).

Návraty

DataStreamReader

Poznámky

Vyžaduje, aby se vývoj zdroje streamování povolil prostřednictvím spark.sql.streaming.enableSourceEvolution konfigurace.

Příklady

Pojmenujte dva zdroje a sjednocujte 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()

Platné a neplatné názvy zdrojů:

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