Freigeben über


option (DataStreamReader)

Fügt eine Eingabeoption für die zugrunde liegende Datenquelle hinzu.

Syntax

option(key, value)

Parameter

Parameter Typ Beschreibung
key str Der Optionsschlüssel.
value str, int, float oder bool Der Optionswert.

Rückkehr

DataStreamReader

Beispiele

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

Generieren Sie 10 Zeilen pro Sekunde mithilfe der Rate-Quelle:

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