按唯一 ID 从中 SparkSession 返回活动流式处理查询。
Syntax
get(id)
参数
| 参数 | 类型 | 说明 |
|---|---|---|
id |
str | 查询的唯一 ID。 |
退货
StreamingQuery
备注
如果具有给定 ID 的活动查询不存在，则会引发异常。
示例
sdf = spark.readStream.format("rate").load()
sq = sdf.writeStream.format('memory').queryName('this_query').start()
sq = spark.streams.get(sq.id)
sq.isActive
# True
sq.stop()