Nóta
Teastaíonn údarú chun rochtain a fháil ar an leathanach seo. Is féidir leat triail a bhaint as shíniú isteach nó eolairí a athrú.
Teastaíonn údarú chun rochtain a fháil ar an leathanach seo. Is féidir leat triail a bhaint as eolairí a athrú.
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()