Module 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 🔒