ess.reduce.streaming.MinAccumulator

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

Keeps the minimum value seen so far.

Only supports scalar values.

__init__(**kwargs)

Parameters:

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

Methods

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

Attributes

is_empty	Check if the accumulator has collected a minimum value.
value	Get the accumulated value.

clear()

Clear the accumulated minimum value.

Return type:

None

property is_empty: bool

Check if the accumulator has collected a minimum value.