ess.reduce.streaming.EternalAccumulator#
- class ess.reduce.streaming.EternalAccumulator(**kwargs)[source]#
Simple accumulator that adds pushed values immediately.
Does not support event data.
- __init__(**kwargs)[source]#
- Parameters:
preprocess – Preprocessing function to be applied to pushed values prior to accumulation.
Methods
__init__(**kwargs)push(value)Push a value to the accumulator.
Attributes
Get the accumulated value.
- property value: T#
Get the accumulated value.
- Returns:
Accumulated value.