הערה
הגישה לדף זה מחייבת הרשאה. באפשרותך לנסות להיכנס או לשנות מדריכי כתובות.
הגישה לדף זה מחייבת הרשאה. באפשרותך לנסות לשנות מדריכי כתובות.
Specifies the name of the StreamingQuery that can be started with start(). This name must be unique among all currently active queries in the associated SparkSession.
Syntax
queryName(queryName)
Parameters
| Parameter | Type | Description |
|---|---|---|
queryName |
str | Unique name for the query. |
Returns
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'