Shengkai Fang created FLINK-20831:
-------------------------------------
Summary: Introduce the in memory topN buffer
Key: FLINK-20831
URL: https://issues.apache.org/jira/browse/FLINK-20831
Project: Flink
Issue Type: New Feature
Components: Table SQL / API
Affects Versions: 1.13.0
Reporter: Shengkai Fang
Fix For: 1.13.0
The buffer is used to cache the record and only keep the topN records. When the
invoker decide to emit or snapshot, it can get the sorted records from the
buffer. The main benfit of the buffer is that it can reduce the per-record
state visit.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
