pyspark.sql.DataFrameReader.option¶
-
DataFrameReader.
option
(key: str, value: OptionalPrimitiveType) → DataFrameReader[source]¶ Adds an input option for the underlying data source.
New in version 1.5.0.
Changed in version 3.4.0: Supports Spark Connect.
- Parameters
- keystr
The key for the option to set.
- value
The value for the option to set.
Examples
>>> spark.read.option("key", "value") <...readwriter.DataFrameReader object ...>
Specify the option ‘nullValue’ with reading a CSV file.
>>> import tempfile >>> with tempfile.TemporaryDirectory() as d: ... # Write a DataFrame into a CSV file ... df = spark.createDataFrame([{"age": 100, "name": "Hyukjin Kwon"}]) ... df.write.mode("overwrite").format("csv").save(d) ... ... # Read the CSV file as a DataFrame with 'nullValue' option set to 'Hyukjin Kwon'. ... spark.read.schema(df.schema).option( ... "nullValue", "Hyukjin Kwon").format('csv').load(d).show() +---+----+ |age|name| +---+----+ |100|NULL| +---+----+