ess.reduce.streaming.MeanAccumulator

class ess.reduce.streaming.MeanAccumulator(**kwargs)

Accumulator that computes the mean of pushed values.

Does not support event data.

__init__(**kwargs)

Parameters:

preprocess – Preprocessing function to be applied to pushed values prior to accumulation.

Methods

__init__(**kwargs)
clear()	Clear the accumulated value and count.
push(value)	Push a value to the accumulator.

Attributes

is_empty	Check if the accumulator is empty.
value	Get the accumulated value.

clear()

Clear the accumulated value and count.

Return type:

None