ess.reduce.streaming.EternalAccumulator

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

Simple accumulator that adds pushed values immediately.

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.
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.

Return type:

None

property is_empty: bool

Check if the accumulator is empty.

Returns:

True if the accumulator is empty, False otherwise.