你可以用 from_json 要分析字符串json值：

val df = Seq(
  """"A":{"B":1,"C":[{"D":2,"E":3},{"D":6,"E":7}]}"""
).toDF("col")

val df1 = df.withColumn(
    "col",
    from_json(
      regexp_extract(col("col"), "\"A\":(.*)", 1), // extract the part after "A":
      lit("struct<B:int,C:array<struct<D:int,E:int>>>")
    )
  ).select(col("col.B"), expr("inline(col.C)"))

df1.show
//+---+---+---+
//|  B|  D|  E|
//+---+---+---+
//|  1|  2|  3|
//|  1|  6|  7|
//+---+---+---+

也可以将架构作为structtype传递给 from_json 函数定义如下：

val schema = StructType(Array(
    StructField("B", IntegerType, true),
    StructField("C", ArrayType(StructType(Array(
            StructField("D", IntegerType, true),
            StructField("E", IntegerType, true)
          ))))
  )
)