オプション（DataStreamWriter）

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

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

構文

option(key, value)

パラメーター

パラメーター	Type	説明
key	str	オプションキー。
value	str、int、float、またはbool	オプション値。

パラメーター	Type	説明
key	str	オプションキー。
value	str、int、float、またはbool	オプション値。

戻り値

DataStreamWriter

例

Python

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

コンソールにバッチごとに3行ずつ出力する：

Python

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