get (StreamingQueryManager)

Renvoie une requête de streaming active de ce SparkSession par son ID unique.

Syntaxe

get(id)

parameter

parameter	Type	Description
id	str	L'ID unique de la query.

parameter	Type	Description
id	str	L'ID unique de la query.

Renvoie

StreamingQuery

Notes

Une exception est levée si une query active avec l'ID donné n'existe pas.

Exemples

Python

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()