Window

Rolling objects are returned by .rolling calls: pandas_on_spark.DataFrame.rolling(), pandas_on_spark.Series.rolling(), etc. Expanding objects are returned by .expanding calls: pandas_on_spark.DataFrame.expanding(), pandas_on_spark.Series.expanding(), etc.

Standard moving window functions

Rolling.count()

The rolling count of any non-NaN observations inside the window.

Rolling.sum()

Calculate rolling summation of given DataFrame or Series.

Rolling.min()

Calculate the rolling minimum.

Rolling.max()

Calculate the rolling maximum.

Rolling.mean()

Calculate the rolling mean of the values.

Standard expanding window functions

Expanding.count()

The expanding count of any non-NaN observations inside the window.

Expanding.sum()

Calculate expanding summation of given DataFrame or Series.

Expanding.min()

Calculate the expanding minimum.

Expanding.max()

Calculate the expanding maximum.

Expanding.mean()

Calculate the expanding mean of the values.