get (StreamingQueryManager)

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()
  • Last updated on