指定可以以 start().. 开头的 StreamingQuery 的名称。 此名称在关联的 SparkSession 中的所有当前活动查询中必须是唯一的。
Syntax
queryName(queryName)
参数
| 参数 | 类型 | Description |
|---|---|---|
queryName |
str | 查询的唯一名称。 |
退货
DataStreamWriter
示例
import time
df = spark.readStream.format("rate").load()
q = df.writeStream.queryName("streaming_query").format("console").start()
q.stop()
q.name
# 'streaming_query'