會根據其唯一 ID 回傳一個主動串流查詢 SparkSession 。
語法
get(id)
參數
| 參數 | 類型 | 說明 |
|---|---|---|
id |
str | 查詢的唯一 ID。 |
退貨
StreamingQuery
Notes
若不存在具有相同 ID 的活躍查詢，則會拋出例外。
Examples
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()