scala - 如何使用字符串数组在spark数据框中将列名称设置为toDF()函数？

例如，

val columns=Array("column1", "column2", "column3")
val df=sc.parallelize(Seq(
(1,"example1", Seq(0,2,5)),
(2,"example2", Seq(1,20,5)))).toDF(columns)

如何使用字符串数组设置列名？
是否可以在toDF()中提及数据类型？

最佳答案

toDF()采用String类型的重复参数，因此您可以使用_*类型注释来传递序列:

val df=sc.parallelize(Seq(
  (1,"example1", Seq(0,2,5)),
  (2,"example2", Seq(1,20,5)))).toDF(columns: _*)

有关重复参数的更多信息，请参见Scala Language Specification中的4.6.2节。

关于scala - 如何使用字符串数组在spark数据框中将列名称设置为toDF()函数？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/37992426/