ess.nmx.streaming.MaxAccumulator

class ess.nmx.streaming.MaxAccumulator(**kwargs)

Accumulator that keeps track of the maximum value seen so far.

__init__(**kwargs)

Parameters:

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

Methods

__init__(**kwargs)
clear()	Clear the accumulator, resetting it to its initial state.
push(value)	Push a value to the accumulator.

Attributes

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

property value: Variable | None

Get the accumulated value.

Returns:

Accumulated value.

Raises:

ValueError – If the accumulator is empty.