使用 from_json()
函数时,请确保列值完全是字符串格式的 json/dictionary。在您提供的示例数据中,列值 Notes
不 id=1
完全是 json 格式(它是一个字符串,但括在额外的单引号中)。 这就是它返回 NULL 值的原因。 在输入数据框上执行以下代码将产生以下输出。
df = df.withColumn("Notes",from_json(df.Notes,MapType(StringType(),StringType())))
您需要更改输入数据,使整个 Notes 列采用相同的格式,即 json/dictionary 作为字符串,仅此而已,因为这是导致问题的主要原因。以下是帮助您解决问题的正确格式。
| ID | Notes |
---------------
| 1 | {"Country":"USA","Count":"1000"} |
| 2 | {"Country":"USA","Count":"1000"} |
要将 Notes 列值解析为 pyspark 中的列,您只需使用调用的函数 json_tuple()
(无需使用 from_json())。它从 json 列(字符串格式)中提取元素并将结果创建为新列。
df = df.select(col("id"),json_tuple(col("Notes"),"Country","Count")) \
.toDF("id","Country","Count")
df.show()
输出:
注意: 如果列值的格式不正确,json_tuple() 也会返回 null(确保列值是 json/dictionary 类型的字符串,没有额外的引号)。