option (DataStreamWriter)

Ajoute une option de sortie pour la source de données sous-jacente.

Pour les options disponibles, consultez les options de DataStreamWriter.

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

DataStreamWriter

Exemples

Python

df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>

Imprimer 3 lignes par batch vers la console :

Python

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