spark sql解析json文件的数组

val ponStatus = df1.select(explode( $" p o n S t a t u s ")) . t o D F (" a l l p o n S t a t u s ") v a l p o n S t a t u s 1 = p o n S t a t u s . s e l e c t ($ “allponStatus.Time” as “Time”,
$“allponStatus.temperature” as “temperature”,
$“allponStatus.voltage” as “voltage”,
$“allponStatus.current” as “current”,
$“allponStatus.ponstatus” as “ponstatus”,
$“allponStatus.txbyte” as “txbyte”,
$“allponStatus.rxbyte” as “rxbyte”,
$“allponStatus.txpkts” as “txpkts”,
$“allponStatus.rxpkts” as “rxpkts”,
$“allponStatus.FECErr” as “FECErr”,
$“allponStatus.dropkts” as “dropkts”)
ponStatus1.createOrReplaceTempView(“ponStatus”)

原文链接：https://blog.csdn.net/busy_programmer/article/details/104457137