json (DataFrameWriter)

DataFrameの内容を JSON 形式 (JSON 行/改行区切り JSON) で指定されたパスに保存します。

構文

json(path, mode=None, compression=None, dateFormat=None, timestampFormat=None,
     lineSep=None, encoding=None, ignoreNullFields=None)

パラメーター

パラメーター タイプ 説明
path str Hadoop でサポートされているファイル システムのパス。
mode str、省略可能 データが既に存在する場合の動作。 使用できる値は、 'append'、 'overwrite'、 'ignore'、 'error' または 'errorifexists' (既定値) です。

返品

なし

例示

JSON ファイルに DataFrame を書き込み、読み戻します。

import tempfile
with tempfile.TemporaryDirectory(prefix="json") as d:
    spark.createDataFrame(
        [{"age": 100, "name": "Alice"}]
    ).write.json(d, mode="overwrite")

    spark.read.format("json").load(d).show()
    # +---+------------+
    # |age|        name|
    # +---+------------+
    # |100|Alice|
    # +---+------------+
  • Last updated on