Met*_*ata 0 scala apache-spark apache-spark-sql
我有一个按以下方式创建的 DataFrame。
val someDF = Seq((8, "bat"),(64, "mouse"),(-27, "horse")).toDF("number", "word")
someDF.printSchema
root
|-- number: integer (nullable = false)
|-- word: string (nullable = true)
Run Code Online (Sandbox Code Playgroud)
使用 SQL API,可以通过创建临时表并运行插入查询向其中插入一行。有什么方法可以使用 DataFrame API 的方法追加/添加新行?
您可以使用union:
val someDF = Seq((8, "bat"),(64, "mouse"),(-27, "horse")).toDF("number", "word")
someDF.union(Seq((10, "dog")).toDF).show
/*
+------+-----+
|number| word|
+------+-----+
| 8| bat|
| 64|mouse|
| -27|horse|
| 10| dog|
+------+-----+
*/
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
1062 次 |
| 最近记录: |