TableValuedFunction.json_tuple

지정된 필드 이름에 따라 json 열에 대한 새 행을 만듭니다.

문법

spark.tvf.json_tuple(input, *fields)

매개 변수

매개 변수	유형	Description
input	pyspark.sql.Column	json 형식의 문자열 열
fields	pyspark.sql.Column	추출할 필드 또는 필드

Returns

pyspark.sql.DataFrame: 추출된 필드 값이 있는 DataFrame입니다.

예시

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

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