擅长:python、mysql、java
<p>首先需要将json解析为<code>Map<String, Integer></code>,然后分解映射。你可以这样做:</p>
<pre><code>import pyspark.sql.types as T
import pyspark.sql.functions as F
...
df2.withColumn("cbgs", F.from_json("cbgs", T.MapType(T.StringType(), T.IntegerType()))).select("id", F.explode("cbgs").alias('cbgs', 'value')).show()
</code></pre>