假设我通过以下方式将 json 文件加载到 Spark 1.6 中
sqlContext.read.json("/hdfs/")
它给了我一个具有以下架构的数据框：
root
|-- id: array (nullable = true)
| |-- element: string (containsNull = true)
|-- checked: array (nullable = true)
| |-- element: string (containsNull = true)
|-- color: array (nullable = true)
| |-- element: string (containsNull = true)
|-- type: array (nullable = true)
| |-- element: string (containsNull = true)
DF 只有一行，里面有我所有项目的数组。
+--------------------+--------------------+--------------------+
| id_e| checked_e| color_e|
+--------------------+--------------------+--------------------+
|[0218797c-77a6-45...|[false, true, tru...|[null, null, null...|
+--------------------+--------------------+--------------------+
我想要一个 DF，其中数组分解为每行一项。
+--------------------+-----+-------+
| id|color|checked| …