Module mz_compute::render::top_k

TopK execution logic.

Consult TopKPlan documentation for details.

Modules

• monoids
  Monoids for in-place compaction of monotonic streams.
• topk_agg
  Types for in-place intra-ts aggregation of monotonic streams.

Functions

• build_topk_negated_stage 🔒
  Build a stage of a topk reduction. Maintains the retractions of the output instead of emitted rows. This has the benefit that we have to maintain state proportionally to size of the output instead of the size of the input.
• render_intra_ts_thinning 🔒