pyspark.pandas.window.Expanding.sum???
-
扩展总和高山市 )++框架相似 ??? -
计算dataFrame或Series扩展和
注解
当前API使用spark窗口时未具体说明分区规范导致单机中所有数据移入单片并可能导致性能严重退化避免此方法对大数据集
- 回归
-
- 数组或数据Frame
-
类型与输入相同并附相同的索引,内含扩展和
并见
-
Series.expanding -
用串行数据调用对象
-
DataFrame.expanding -
调用对象dataFrames
-
数列.sum -
串行压缩和
-
DataFrame.sum -
DataFrame压缩和
实例
>>>s级=ss系统.串行〔一号,2,3,4,5)>>>s级01一二二三3445d类型:int64
>>>s级.扩展高山市3).总和(b)0N1N26.0310.0415.0d类型:浮点64
对DataFrame而言,每个扩展加法均按列计算
>>>df=ss系统.数据Frame{{A级:s级.to_numpy(b),B级:s级.to_numpy(b)网际网际网际网路2}>>>dfAB01一二四二三九34164525
>>>df.扩展高山市3).总和(b)AB0NNN纳纳2.6.014.0310.030.0415.055.0