この SparkSession からアクティブなストリーミング クエリを一意の ID で返します。
構文
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()