Muistiinpano
Tämän sivun käyttö edellyttää valtuutusta. Voit yrittää kirjautua sisään tai vaihtaa hakemistoa.
Tämän sivun käyttö edellyttää valtuutusta. Voit yrittää vaihtaa hakemistoa.
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()