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.

Constants

FLOAT_SCALE 🔒

The fixed-point scale applied to float sums, i.e. 2^FLOAT_SCALE_EXP.

FLOAT_SCALE_EXP 🔒

The number of fractional bits of binary precision retained by the fixed-point representation used to accumulate float sums. The fixed-point scale is FLOAT_SCALE == 2^FLOAT_SCALE_EXP.

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 🔒

float_to_fixed_point 🔒

Maps a finite f64 onto the fixed-point i128 domain used to accumulate float sums, i.e. computes trunc(n * FLOAT_SCALE) reduced modulo 2^128.

Type Aliases

AccumCount 🔒

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