PySpark利用udf新增一列

在PySpark中,对DataFrame新增一列有几种写法: df=spark.createDataFrame([('p1',56),('p2',23),('p3',11),('p4',40),('p5',29)],['name','age']) df.show() >> + + + |name|a
posted @ 2021-10-27 16:50  morein2008  阅读(845)  评论(0编辑  收藏  举报