将包含 JSON 字符串的列分析为 .VariantType 如果字符串表示无效的 JSON 值，则引发异常。
Syntax
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}')]