求教： Spark的dataframe 怎么改列的名字，比如列名 SUM(_c1) 改成c1

发布网友发布时间：2022-04-26 17:26

共3个回答

热心网友时间：2023-10-17 05:45

试试这样：

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

热心网友时间：2023-10-17 05:45

看这问题人挺多的，我来提供一下解决方案.
DF.sum("value").withColumnRenamed("sum(value)","sumType").show();

热心网友时间：2023-10-17 05:45

兄弟你可以这样：
from pyspark.sql import functions as F
df.groupBy("keyy").agg(F.sum('_c1').alias('c1'), F.sum('_c2').alias('c2')).collect()

求教: Spark的dataframe 怎么改列的名字,比如列名 SUM(_c1) 改成c1

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

python2 之DataFrame

选取与删除: DataFrame的选取和删除功能强大。选取特定值的所有行或列、特定条件的行或列，使用df[df['条件']]。使用索引或列名获取特定数据。删除操作包括删除特定列、行或满足特定条件的行。计算: DataFrame提供丰富的计算方法，如计算均值、中位数、最大值、最小值等，使用df.mean()、df.median()...

python转学sas多久(python导入sas文件)

1、开头、结尾、输出名称前三个部分非常简单。使用正则表达式删除多余的行,然后将脚本的开头更改为DATApred_result;\nSETdataset_name;。使用过SAS的同学就很熟悉了,pred_result是运行SAS脚本后的输出表名称,dataset_name是我们需要预测的输入表名称。最后再将脚本的结尾更改为RUN;。 #移除SAS中不能使用的代码 ...

python转学sas多久(python导入sas文件)

修改dataframe一列的值 dataframe列求和 dataframe增加求和列 dataframe取列 dataframe添加列 dataframe按列排序 dataframe一列排序 dataframe特定列 dataframe提取某几列