option (DataStreamWriter)

Dodaje opcję danych wyjściowych dla bazowego źródła danych.

Składnia

option(key, value)

Parametry

Parameter	Typ	Opis
key	str	Klucz opcji.
value	str, int, float lub bool	Wartość opcji.

Zwroty

DataStreamWriter

Examples

df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>

Drukuj 3 wiersze na partię w konsoli:

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