queryName (DataStreamWriter)

Menentukan nama StreamingQuery yang dapat dimulai dengan start(). Nama ini harus unik di antara semua kueri yang saat ini aktif di SparkSession terkait.

Sintaksis

queryName(queryName)

Parameter-parameternya

Parameter	Tipe	Deskripsi
queryName	str	Nama unik untuk kueri.

Pengembalian Barang

DataStreamWriter

Examples

import time
df = spark.readStream.format("rate").load()
q = df.writeStream.queryName("streaming_query").format("console").start()
q.stop()
q.name
# 'streaming_query'