Remarque
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de vous connecter ou de modifier des répertoires.
L’accès à cette page nécessite une autorisation. Vous pouvez essayer de modifier des répertoires.
Retourne une requête de diffusion en continu active à partir de celle-ci SparkSession par son ID unique.
Syntaxe
get(id)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
id |
str | ID unique de la requête. |
Retours
StreamingQuery
Remarques
Une exception est levée si une requête active avec l’ID donné n’existe pas.
Exemples
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()