基になるデータ ソースの入力オプションを追加します。
構文
option(key, value)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
key |
str | オプション キー。 |
value |
str、int、float、または bool | オプション値。 |
返品
DataStreamReader
例示
spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>
レート ソースを使用して 1 秒あたり 10 行を生成します。
import time
q = spark.readStream.format(
"rate").option("rowsPerSecond", 10).load().writeStream.format("console").start()
time.sleep(3)
q.stop()