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.

map_topk_key 🔒

Forms the (key, value) arrangement input the TopK stages consume.

render_intra_ts_thinning 🔒

topk_result_to_columnar 🔒

Drops the hash-key pairing from a consolidated (hash_key, row) TopK result.