text (DataFrameReader)

Načte textové soubory a vrátí DataFrame schéma, jehož schéma začíná řetězcem sloupce s názvem value, následované dělenými sloupci, pokud existují. Textové soubory musí být kódovány jako UTF-8. Ve výchozím nastavení je každý řádek v textovém souboru novým řádkem ve výsledném datovém rámci.

Syntaxe

text(paths, wholetext=False, lineSep=None, **options)

Parametry

Parameter	Typ	Description
paths	str nebo list	Jedna nebo více vstupních cest.
wholetext	bool, volitelné	Pokud True, číst každý soubor jako jeden řádek. Výchozí hodnota je False.
lineSep	str, volitelné	Oddělovač čar, který chcete použít. Výchozí hodnota je '\n', '\r'nebo '\r\n'.

Návraty

DataFrame

Příklady

Zapište datový rámec do textového souboru a přečtěte si ho zpátky.

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

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