option (DataFrameReader)

Добавляет входной параметр для базового источника данных.

Доступные параметры см. в разделе "Параметры DataFrameReader".

Синтаксис

option(key, value)

Параметры

Параметр Тип Описание
key str Клавиша Option.
value str, int, float или bool Значение параметра.

Возвраты

DataFrameReader

Примеры

Чтение CSV-файла с набором nullValue параметров.

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|
    # +---+----+