由于一些奇怪的原因,我需要获取 Dataframe 的列名并将其插入第一行(我不能只导入没有标题的数据)。我尝试使用for comprehension创建一个只有1行30列(有30个标题)的 Dataframe ,并将其联合到原始 Dataframe 。但是我得到的是一个只有1行和1列的 Dataframe ,其值是30个字符串的列表。
我尝试的是:
val headerDF = Seq((for (col <- data.columns) yield col)).toDF
display(headerDF)
字符串
| Column A |
| ------------ |
| ["col1", "col2", "col3", ...] |
预期行为:
| B栏|B栏| Column B |
| --|--| ------------ |
| col2| Col3| Col3 |
1条答案
按热度按时间m3eecexj1#
一种解决方案是使用
spark.range(1)
创建一个单行 Dataframe ,然后像这样为每个列名创建一个列:x
的数据