添加基础数据源的输入选项。
Syntax
option(key, value)
参数
| 参数 | 类型 | 说明 |
|---|---|---|
key |
str | 选项键。 |
value |
str、int、float 或 bool | 选项值。 |
退货
DataFrameReader
示例
读取包含选项集的 nullValue CSV 文件。
import tempfile
with tempfile.TemporaryDirectory(prefix="option") as d:
df = spark.createDataFrame([{"age": 100, "name": "Alice"}])
df.write.mode("overwrite").format("csv").save(d)
spark.read.schema(df.schema).option(
"nullValue", "Alice").format('csv').load(d).show()
# +---+----+
# |age|name|
# +---+----+
# |100|NULL|
# +---+----+