Nota
L-aċċess għal din il-paġna jeħtieġ l-awtorizzazzjoni. Tista’ tipprova tidħol jew tibdel id-direttorji.
L-aċċess għal din il-paġna jeħtieġ l-awtorizzazzjoni. Tista’ tipprova tibdel id-direttorji.
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()