オプション(DataFrameReader)
基となるデータソースへの入力オプションを追加します。
構文
options(**options)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
| 辞書 | 文字列キーがプリミティブ型の値にマッピングされます。利用可能なオプションについては、 DataFrameReader のオプションを参照してください。 |
戻り値
DataFrameReader
例
nullValueとheaderオプションが設定されたCSVファイルを読み込みます。
Python
import tempfile
with tempfile.TemporaryDirectory(prefix="options") as d:
df = spark.createDataFrame([{"age": 100, "name": "Alice"}])
df.write.option("header", True).mode("overwrite").format("csv").save(d)
spark.read.options(
nullValue="Alice",
header=True
).format('csv').load(d).show()
# +---+----+
# |age|name|
# +---+----+
# |100|NULL|
# +---+----+