Module reduce

Reduction dataflow construction.

Consult ReducePlan documentation for details.

Modules

monoids 🔒

Monoids for in-place compaction of monotonic streams.

window_agg_helpers 🔒

Enums

Accum 🔒

Accumulates values for the various types of accumulable aggregations.

Statics

FLOAT_SCALE 🔒

Functions

accumulable_zero 🔒

datum_to_accumulator 🔒

evaluate_mfp_after 🔒

Evaluates the fused MFP, if one exists, on a reconstructed DatumVecBorrow containing key and aggregate values, then returns a result Row or None if the MFP filters the result out.

finalize_accum 🔒

Type Aliases

AccumCount 🔒

The type for accumulator counting. Set to Overflowing<u128>.