Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Fügt eine Eingabeoption für die zugrunde liegende Datenquelle hinzu.
Verfügbare Optionen finden Sie unter DataStreamReader-Optionen.
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()