指定可以 start()為起始的 StreamingQuery 名稱。 此名稱必須在所有目前啟用的 SparkSession 查詢中唯一。
語法
queryName(queryName)
參數
| 參數 | 類型 | 說明 |
|---|---|---|
queryName |
str | 查詢名稱獨特。 |
退貨
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'