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

value

Get the accumulated value.
property value: T#

Get the accumulated value.

Returns:

Accumulated value.