text (DataFrameWriter)

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

構文

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

パラメーター

パラメーター タイプ 説明
path str Hadoop でサポートされているファイル システムのパス。
compression str、省略可能 使用する圧縮コーデック。
lineSep str、省略可能 使用する行区切り記号。

返品

なし

メモ

DataFrameには、文字列型の列が 1 つだけ必要です。 各行は、出力ファイル内の新しい行になります。

例示

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|
    # +---------+
  • Last updated on