Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Hiermee wordt een actieve streamingquery geretourneerd op basis van de SparkSession unieke id.
Syntaxis
get(id)
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
id |
str | De unieke id van de query. |
Retouren
StreamingQuery
Aantekeningen
Er wordt een uitzondering gegenereerd als er geen actieve query met de opgegeven id bestaat.
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()