szöveg (DataFrameWriter)

A megadott elérési úton menti a DataFrame szövegfájl tartalmát. A szövegfájlok kódolása UTF-8.

Szemantika

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

Paraméterek

Paraméter	Típus	Leírás
path	str	Bármely Hadoop által támogatott fájlrendszer elérési útja.
compression	str, nem kötelező	A használni kívánt tömörítési kodek.
lineSep	str, nem kötelező	A használni kívánt vonalelválasztó.

Visszatérítések

Nincs

Jegyzetek

A DataFrame sztring típusú oszlopnak csak egy oszlopa lehet. Minden sor új sor lesz a kimeneti fájlban.

Examples

Írjon egy DataFrame-et egy szövegfájlba, és olvassa vissza.

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