ess.reduce.streaming.RollingAccumulator#
- class ess.reduce.streaming.RollingAccumulator(window=10, **kwargs)[source]#
Accumulator that adds pushed values to a rolling window.
Does not support event data.
- __init__(window=10, **kwargs)[source]#
- Parameters:
window (
int, default:10) – Size of the rolling window.
Methods
__init__([window])push(value)Push a value to the accumulator.
Attributes
Get the accumulated value.
- property value: T#
Get the accumulated value.
- Returns:
Accumulated value.