이 쿼리의 SparkSession 활성 스트리밍 쿼리를 고유 ID로 반환합니다.
문법
get(id)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
id |
str | 쿼리의 고유 ID입니다. |
Returns
StreamingQuery
Notes
지정된 ID를 가진 활성 쿼리가 없으면 예외가 throw됩니다.
예제
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()