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 d’entrée pour la source de données sous-jacente.
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
DataStreamReader
Exemples
spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>
Générez 10 lignes par seconde à l’aide de la source rate :
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format("console").start()
time.sleep(3)
q.stop()