options (DataStreamReader)

Přidá více vstupních možností pro podkladový zdroj dat.

Dostupné možnosti najdete v tématu Možnosti třídy DataStreamReader.

Syntaxe

options(**options)

Parametry

Parameter	Typ	Description
**options	slovník	Páry klíč-hodnota možností.

Návraty

DataStreamReader

Příklady

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

Zadejte možnosti jako slovník:

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

Vygenerujte 10 řádků za sekundu s 10 oddíly pomocí zdroje rate:

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