JSON 文字列を含む列を VariantTypeに解析します。 文字列が無効な JSON 値を表す場合、例外をスローします。
構文
from pyspark.sql import functions as sf
sf.parse_json(col)
パラメーター
| パラメーター | タイプ | Description |
|---|---|---|
col |
pyspark.sql.Column または str |
JSON 形式の列または列名の文字列。 |
返品ポリシー
pyspark.sql.Column: VariantType の新しい列。
例示
from pyspark.sql import functions as sf
df = spark.createDataFrame([ {'json': '''{ "a" : 1 }'''} ])
df.select(sf.to_json(sf.parse_json(df.json))).collect()
[Row(to_json(parse_json(json))='{"a":1}')]