options (DataStreamWriter)

Ajoute plusieurs options de sortie pour la source de données sous-jacente.

Pour les options disponibles, consultez les options de DataStreamWriter.

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

DataStreamWriter

Exemples

Python

df = spark.readStream.format("rate").load()
df.writeStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamWriter object ...>

Imprimer 3 lignes par batch sans troncature :

Python

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