オプション（DataStreamReader）

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

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

構文

option(key, value)

パラメーター

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

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

戻り値

DataStreamReader

例

Python

spark.readStream.option("x", 1)
# <...streaming.readwriter.DataStreamReader object ...>

Rate ソースを使用して 1 秒あたり 10 行を生成します。

Python

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