小编mah*_*pal的帖子

如何从spark中的嵌套结构类型中提取列名和数据类型

如何从spark中的嵌套结构类型中提取列名和数据类型

模式变得像这样:

(events,StructType(
   StructField(beaconType,StringType,true),     
   StructField(beaconVersion,StringType,true), 
   StructField(client,StringType,true), 
   StructField(data,StructType(
      StructField(ad,StructType(
         StructField(adId,StringType,true)
      )
   )
)
Run Code Online (Sandbox Code Playgroud)

我想转换成下面的格式

Array[(String, String)] = Array(
  (client,StringType), 
  (beaconType,StringType), 
  (beaconVersion,StringType), 
  (phase,StringType)
Run Code Online (Sandbox Code Playgroud)

你能帮忙吗

scala apache-spark

4
推荐指数
1
解决办法
2万
查看次数

标签 统计

apache-spark ×1

scala ×1