窗口

滚动对象返回.滚动调用 :pandas_on_spark.DataFrame.rolling(),pandas_on_spark.Series.rolling()等类扩展对象由返回.扩展调用 :pandas_on_spark.DataFrame.expanding(),pandas_on_spark.Series.expanding()等类指针移动对象由返回.Wem调用 :pandas_on_spark.DataFrame.ewm(),pandas_on_spark.Series.ewm()等类

标准移动窗口函数

滚动.计数(b)	滚动计数窗口内非NN观察
滚动.和(b)	计算dataFrame或Series滚动汇总
滚动.min(b)	计算最小滚动
滚动.max(b)	计算最大滚动量
滚动. mean(b)	计算滚动值

标准扩展窗口函数

扩展.计数(b)	扩展数窗口内非NN观察
扩展.和(b)	计算dataFrame或Series扩展和
扩展.min(b)	计算扩展最小值
展开.max(b)	计算最大扩展量
扩展. mean(b)	计算值扩展平均值

指针移动窗口函数

ExponentialMoving.mean(b)

计算在线指数加权平均值

前一

pyspark.pandas.TimedeltaIndex.microseconds

下一个

pyspark.pandas.window.Rolling.count