text (DataFrameWriter)

Сохраняет содержимое текстового DataFrame файла по указанному пути. Текстовые файлы кодируются как UTF-8.

Синтаксис

text(path, compression=None, lineSep=None)

Параметры

Параметр	Тип	Описание
path	str	Путь в любой файловой системе, поддерживаемой Hadoop.
compression	str, необязательный	Используемый кодек сжатия.
lineSep	str, необязательный	Используемый разделитель строк.

Возвраты

Нет

Примечания

Должен DataFrame иметь только один столбец типа строки. Каждая строка становится новой строкой в выходном файле.

Примеры

Напишите кадр данных в текстовый файл и считывает его обратно.

import tempfile
with tempfile.TemporaryDirectory(prefix="text") as d:
    df = spark.createDataFrame([("a",), ("b",), ("c",)], schema=["alphabets"])
    df.write.mode("overwrite").text(d)

    spark.read.schema(df.schema).format("text").load(d).sort("alphabets").show()
    # +---------+
    # |alphabets|
    # +---------+
    # |        a|
    # |        b|
    # |        c|
    # +---------+