擅长:python、mysql、java
<p>下面是如何实现的,希望您可以将其更改为python</p>
<p>使用值中的<code>schema_of_json</code>动态获取模式,并使用<code>from_json</code>进行读取</p>
<pre><code>val schema = schema_of_json(df.first().getAs[String]("params"))
df.withColumn("params", from_json($"params", schema))
.select("id1", "id2", "Col2", "params.*")
.show(false)
</code></pre>