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.
Spécifie le nom de StreamingQuery qui peut être démarré avec start(). Ce nom doit être unique parmi toutes les requêtes actuellement actives dans sparkSession associée.
Syntaxe
queryName(queryName)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
queryName |
str | Nom unique de la requête. |
Retours
DataStreamWriter
Exemples
import time
df = spark.readStream.format("rate").load()
q = df.writeStream.queryName("streaming_query").format("console").start()
q.stop()
q.name
# 'streaming_query'