Window

滚动对象由 .rolling 调用返回： pyspark.pandas.DataFrame.rolling() 、 pyspark.pandas.Series.rolling() 等。

扩展对象由 .expanding 调用返回： pyspark.pandas.DataFrame.expanding() 、 pyspark.pandas.Series.expanding() 等。

ExponentialMoving 对象由 .ewm 调用返回： pyspark.pandas.DataFrame.ewm() 、 pyspark.pandas.Series.ewm() 等。

Standard moving window functions

Rolling.count ()	窗口内任意非NaN观测值的滚动计数。
Rolling.sum ()	计算给定DataFrame或Series的滚动求和。
Rolling.min ()	计算滚动最小值。
Rolling.max ()	计算滚动最大值。
Rolling.mean ()	计算值的滚动平均值。
Rolling.quantile (分位数[, 准确度])	计算值的滚动分位数。

Standard expanding window functions

Expanding.count ()	窗口内非NaN观测值的扩展计数。
Expanding.sum ()	计算给定DataFrame或Series的扩展求和。
Expanding.min ()	计算扩展最小值。
Expanding.max ()	计算扩展的最大值。
Expanding.mean ()	计算值的扩展平均值。
Expanding.quantile (分位数[, 准确度])	计算值的扩展分位数。

Exponential moving window functions

ExponentialMoving.mean ()

计算在线指数加权平均值。

上一篇

pyspark.pandas.TimedeltaIndex.微秒

下一页

pyspark.pandas.窗口.滚动.计数