Note
Access to this page requires authorization. You can try signing in or changing directories.
Access to this page requires authorization. You can try changing directories.
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()