オプション（DataStreamReader）

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

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

構文

options(**options)

パラメーター

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

戻り値

DataStreamReader

例

Python

spark.readStream.options(x="1", y=2)
# <...streaming.readwriter.DataStreamReader object ...>

オプションは辞書形式で指定します。

Python

spark.readStream.options(**{"k1": "v1", "k2": "v2"})
# <...streaming.readwriter.DataStreamReader object ...>

Rate 設定を使用して、10個のパーティションで毎秒10行を生成します。

Python

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