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.
Ajoute une option de sortie pour la source de données sous-jacente.
Pour connaître les options disponibles, consultez les options DataStreamWriter.
Syntaxe
option(key, value)
Paramètres
| Paramètre | Type | Description |
|---|---|---|
key |
str | La clé d’option. |
value |
str, int, float ou bool | Valeur de l’option. |
Retours
DataStreamWriter
Exemples
df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>
Imprimez 3 lignes par lot dans la console :
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").option("numRows", 3).start()
time.sleep(3)
q.stop()