pyspark将新行添加到数据框

Question

我试图将新行添加到数据框，但不能。

我的代码：

newRow = Row(id='ID123')
newDF= df.insertInto(newRow)
 or 
newDF= df.union(newRow)

错误：

AttributeError: _jdf

AttributeError: 'DataFrame' object has no attribute 'insertInto'

Answer 1

使用pyspark在数据框中添加行的简单方法

newRow = spark.createDataFrame([(15,'Alk','Dhl')])
df = df.union(newRow)
df.show()

Answer 2

尝试：（文档）

from pyspark.sql import Row
newDf = sc.parallelize([Row(id='ID123')]).toDF()
newDF.show()