sunjincheng created FLINK-6219: ---------------------------------- Summary: Add a state backend which supports sorting Key: FLINK-6219 URL: https://issues.apache.org/jira/browse/FLINK-6219 Project: Flink Issue Type: New Feature Components: State Backends, Checkpointing, Table API & SQL Reporter: sunjincheng
When we implement the OVER window of [FLIP11|https://cwiki.apache.org/confluence/display/FLINK/FLIP-11%3A+Table+API+Stream+Aggregations] We notice that we need a state backend which supports sorting, allows for efficient insertion, traversal in order, and removal from the head. For example: In event-time OVER window, we need to sort by time,If the datas as follow: {code} (1L, 1, Hello) (2L, 2, Hello) (5L, 5, Hello) (4L, 4, Hello) {code} We randomly insert the datas, just like: {code} put((2L, 2, Hello)),put((1L, 1, Hello)),put((5L, 5, Hello)),put((4L, 4, Hello)), {code} We deal with elements in time order: {code} process((1L, 1, Hello)),process((2L, 2, Hello)),process((4L, 4, Hello)),process((5L, 5, Hello)) {code} Welcome anyone to give feedback,And what do you think? [~xiaogang.shi] [~aljoscha] [~fhueske] -- This message was sent by Atlassian JIRA (v6.3.15#6346)