risingwave_stream::executor::top_n

Module top_n_plain

Source

Structs§

InnerTopNExecutor

Type Aliases§

TopNExecutor
TopNExecutor works with input with modification, it keeps all the data records/rows that have been seen, and returns topN records overall.