options (DataStreamReader)

Ajoute plusieurs options d'entrée pour la source de données sous-jacente.

Pour les options disponibles, consultez Options DataStreamReader.

Syntaxe

options(**options)

parameter

parameter	Type	Description
**options	dict	Paires clé-valeur d'options.

parameter	Type	Description
**options	dict	Paires clé-valeur d'options.

Renvoie

DataStreamReader

Exemples

Python

spark.readStream.options(x="1", y=2)
# <...streaming.readwriter.DataStreamReader object ...>

Spécifiez les options sous forme de dictionnaire :

Python

spark.readStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamReader object ...>

Générez 10 lignes par seconde avec 10 partitions en utilisant la source de débit :

Python

import time
q = spark.readStream.format("rate").options(
    rowsPerSecond=10, numPartitions=10
).load().writeStream.format("console").start()
time.sleep(3)
q.stop()