如何在scala中对数组使用explode函数

Question

我有以下数据框：

_name	data
Test	{[{0, 0, 1, 0 }]}

我希望输出为：

allNames	data
Test	0
Test	0
Test	1
Test	1

我尝试了explode函数，但是下面的代码只是返回了与上面相同的数据帧，只是标题发生了变化。如何更改代码以获得预期的输出？

  val t = cabinetDF.select(col("_attrname").as("allNames"),functions.explode(array(col("ROWDATA"))))
  t.show(false)

Answer 1

这对我有用，但是我正在创建一个普通数组。我不知道为什么你的被额外的一组花括号和一组额外的方括号括起来：

import org.apache.spark.sql.functions._
import spark.sqlContext.implicits._

val df = Seq( ("Test", Array( 0, 0, 1, 0 ) ) )
  .toDF("_name", "data")

df.show

val df2 = df
  .withColumn("x", explode($"data"))
  .select("_name", "x")
  
df2.show

我的结果：

也许你需要先解压它，或者首先看看它是如何创建的。