テキスト（DataFrameWriter）

DataFrameの内容を、指定されたパスにあるテキストファイルに保存します。テキストファイルはUTF-8でエンコードされます。

構文

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

パラメーター

パラメーター	Type	説明
path	str	Hadoopがサポートするファイルシステム上のパス。
compression	文字列、オプション	使用する圧縮コーデック。
lineSep	文字列、オプション	使用する行区切り文字。

戻り値

なし

注意

DataFrameには文字列型の列が1つだけ含まれていなければなりません。各行は出力ファイル内の新しい行になります。

例

DataFrameをテキストファイルに書き込み、それを読み込む。

Python

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