テーブル値関数.json_tuple

指定されたフィールド名に従って、JSON 列の新しい行を作成します。

構文

Python

spark.tvf.json_tuple(input, *fields)

パラメーター

パラメーター	Type	説明
input	pyspark.sql.Column	JSON形式の文字列列
fields	pyspark.sql.Column	抽出するフィールド

戻り値

pyspark.sql.DataFrame: 抽出されたフィールド値を含む DataFrame。

例

Python

import pyspark.sql.functions as sf
spark.tvf.json_tuple(
    sf.lit('{"f1": "value1", "f2": "value2"}'), sf.lit("f1"), sf.lit("f2")
).show()

Output

+------+------+
|    c0|    c1|
+------+------+
|value1|value2|
+------+------+