options (DataStreamWriter)

Temel alınan veri kaynağı için birden çok çıkış seçeneği ekler.

Kullanılabilir seçenekler için bkz . DataStreamWriter seçenekleri.

Sözdizimi

options(**options)

Parametreler

Parametre	Türü	Açıklama
**options	Dict	Anahtar-değer seçenekleri çiftleri.

İadeler

DataStreamWriter

Örnekler

df = spark.readStream.format("rate").load()
df.writeStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamWriter object ...>

Kesme olmadan toplu iş başına 3 satır yazdırın:

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