Kommentar
Åtkomst till den här sidan kräver auktorisering. Du kan prova att logga in eller ändra kataloger.
Åtkomst till den här sidan kräver auktorisering. Du kan prova att ändra kataloger.
Lägger till ett utdataalternativ för den underliggande datakällan.
Tillgängliga alternativ finns i DataStreamWriter-alternativ.
Syntax
option(key, value)
Parameters
| Parameter | Type | Beskrivning |
|---|---|---|
key |
str | Alternativnyckeln. |
value |
str, int, float eller bool | Alternativvärdet. |
Retur
DataStreamWriter
Exempel
df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>
Skriv ut 3 rader per batch till konsolen:
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").option("numRows", 3).start()
time.sleep(3)
q.stop()