nama (DataStreamReader)

Menetapkan nama ke sumber streaming untuk evolusi titik pemeriksaan. Ini memungkinkan kueri streaming berevolusi dengan memungkinkan sumber diurutkan ulang atau ditambahkan tanpa melanggar kompatibilitas titik pemeriksaan. Ketika evolusi sumber diaktifkan, semua sumber dalam kueri harus diberi nama.

Sintaksis

name(source_name)

Parameter-parameternya

Parameter	Tipe	Deskripsi
source_name	str	Nama untuk sumber streaming ini. Hanya boleh berisi huruf ASCII (a-z, A-Z), digit (0-9), dan garis bawah (_).

Pengembalian Barang

DataStreamReader

Catatan

Mengharuskan evolusi sumber streaming diaktifkan melalui spark.sql.streaming.enableSourceEvolution konfigurasi.

Examples

Beri nama dua sumber dan satukan sumber:

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

Nama sumber yang valid dan tidak valid:

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