请问有什么办法能把这个dataframe的列名改成正常的名字吗?

做了一个groupBy().agg()之后,
df.groupBy("keyy").agg({"_c1" : "sum", "_c2" : "sum"})

数据就变成了这样的格式。
newdf :
[Row(keyy=u'aaa', SUM(_c1)=0.123,SUM(_c2)=0.567),
Row(keyy=u'bbb', SUM(_c1)=0.234, SUM(_c2)=0.567)]

因为接下来还要对后面两列进行操作,发现sql 或者直接选取列都因为这奇葩(?)的列名,都不能运行。有什么办法能把这个dataframe的列名改成正常的名字, 比如c1之类的?只要能让后面的调用,麻烦点的方法都可以,不用考虑perforamance.........
newdf里, SUM(_c1) SUM(_c2) 不一定一个在前一个在后,有时候可能是【keyy ,SUM(_c2),SUM(_c1) 】
多谢多谢!

慕田峪4524236
浏览 137回答 2
2回答

慕码人8056858

试试这样:df.groupBy("key").agg(sum($"quantity") as "c1", avg($"quantity") as "c2")

ABOUTYOU

兄弟 你可以这样:from pyspark.sql import functions as Fdf.groupBy("keyy").agg(F.sum('_c1').alias('c1'), F.sum('_c2').alias('c2')).collect()
打开App,查看更多内容
随时随地看视频慕课网APP