窗口

返回的對象.rolling電話:pandas_on_spark.DataFrame.rolling (),pandas_on_spark.Series.rolling ()等。擴大返回的對象.expanding電話:pandas_on_spark.DataFrame.expanding (),pandas_on_spark.Series.expanding ()等ExponentialMoving對象返回.ewm電話:pandas_on_spark.DataFrame.ewm (),pandas_on_spark.Series.ewm ()等。

標準的移動窗口功能

Rolling.count()	滾動窗口內的任何non-NaN觀察計數。
Rolling.sum()	計算滾動DataFrame或係列的總和。
Rolling.min()	計算最小。
Rolling.max()	計算最大。
Rolling.mean()	計算值的滾動的意思。

標準擴大窗口函數

Expanding.count()	擴大計數non-NaN觀察窗內。
Expanding.sum()	計算求和DataFrame或係列的擴張。
Expanding.min()	計算最小擴張。
Expanding.max()	計算最大擴張。
Expanding.mean()	計算值的擴大意味著。

指數移動窗口功能

ExponentialMoving.mean()

在線指數加權平均數計算。

以前的

pyspark.pandas.TimedeltaIndex.microseconds

下一個

pyspark.pandas.window.Rolling.count