向pyspark Dataframe添加新行

向pyspark Dataframe添加新行,第1张

向pyspark Dataframe添加新行

正如bluephantom已经说过的那样,工会是要走的路。我只是在回答您的问题,以举一个pyspark示例

# if not already created automatically, instantiate Sparkcontextspark = SparkSession.builder.getOrCreate()columns = ['id', 'dogs', 'cats']vals = [(1, 2, 0), (2, 0, 1)]df = spark.createDataframe(vals, columns)newRow = spark.createDataframe([(4,5,7)], columns)appended = df.union(newRow)appended.show()

也请查看databricks常见问题解答:https://kb.databricks.com/data/append-a-row-to-rdd-or-
dataframe.html



欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5566063.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-14
下一篇 2022-12-14

发表评论

登录后才能评论

评论列表(0条)

保存