option (DataStreamReader)

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

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

Syntaxe

option(key, value)

Parametry

Parameter Typ Description
key str Klávesa option.
value str, int, float nebo bool Hodnota možnosti.

Návraty

DataStreamReader

Příklady

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

Generovat 10 řádků za sekundu pomocí zdroje rate:

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