הערה
הגישה לדף זה מחייבת הרשאה. באפשרותך לנסות להיכנס או לשנות מדריכי כתובות.
הגישה לדף זה מחייבת הרשאה. באפשרותך לנסות לשנות מדריכי כתובות.
Returns an active streaming query from this SparkSession by its unique ID.
Syntax
get(id)
Parameters
| Parameter | Type | Description |
|---|---|---|
id |
str | The unique ID of the query. |
Returns
StreamingQuery
Notes
An exception is thrown if an active query with the given ID does not exist.
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()