get (StreamingQueryManager)
このSparkSessionから、一意の ID でアクティブなストリーミングクエリを返します。
構文
get(id)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| str | クエリの一意のID。 |
戻り値
StreamingQuery
注意
指定されたIDを持つアクティブなクエリが存在しない場合、例外がスローされます。
例
Python
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()