risingwave_stream::executor::top_n

Module top_n_plain

source

Structs§

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.