Module accum

Accumulators for aggregate functions that’s is accumulatable. i.e. sum/count

Accumulator will only be restore from row and being updated every time dataflow need process a new batch of rows. So the overhead is acceptable.

Currently support sum, count, any, all and min/max(with one caveat that min/max can’t support delete with aggregate). TODO: think of better ways to not ser/de every time a accum needed to be updated, since it’s in a tight loop

Structs

Bool

Bool accumulator, used for Any All Max/MinBool

Float

Accumulates float values for sum over floating numbers.

OrdValue

Accumulates a single Orded Value, useful for min/max aggregations.

SimpleNumber

Accumulates simple numeric values for sum over integer.

Enums

Accum

Accumulates values for the various types of accumulable aggregations.

Traits

Accumulator

Accumulates values for the various types of accumulable aggregations.

Functions

err_try_from_val 🔒

fail_accum 🔒

ty_eq_without_precision 🔒

compare type while ignore their precision, including TimeStamp, Time, Duration, Interval