option (DataStreamReader)

Ajouter une option d'entrée pour la source de données sous-jacente.

Pour les options disponibles, consultez Options DataStreamReader.

Syntaxe

option(key, value)

parameter

parameter	Type	Description
key	str	La clé d’option.
value	str, int, float ou bool	La valeur de l'option.

parameter	Type	Description
key	str	La clé d’option.
value	str, int, float ou bool	La valeur de l'option.

Renvoie

DataStreamReader

Exemples

Python

spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>

Générer 10 lignes par seconde à l'aide de la source Taux :

Python

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