オプション（DataStreamWriter）

基となるデータソースに対して、複数の出力オプションを追加します。

利用可能なオプションについては、 DataStreamWriter のオプションを参照してください。

構文

options(**options)

パラメーター

パラメーター	Type	説明
**options	辞書	オプションのキーと値のペア。

戻り値

DataStreamWriter

例

Python

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

切り詰めずにバッチごとに 3 行を印刷します。

Python

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()