ess.reduce.streaming.Accumulator#
- class ess.reduce.streaming.Accumulator(preprocess=<function maybe_hist>)[source]#
Abstract base class for accumulators.
Accumulators are used to accumulate values over multiple chunks.
Methods
Attributes
Get the accumulated value.
- abstract property value: T#
Get the accumulated value.
- Returns:
Accumulated value.