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 🔒