基になるデータ ソースの出力オプションを追加します。
構文
option(key, value)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
key |
str | オプション キー。 |
value |
str、int、float、または bool | オプション値。 |
返品
DataStreamWriter
例示
df = spark.readStream.format("rate").load()
df.writeStream.option("x", 1)
# <...streaming.readwriter.DataStreamWriter object ...>
バッチごとに 3 行をコンソールに出力します。
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format(
"console").option("numRows", 3).start()
time.sleep(3)
q.stop()