[ https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197188#comment-16197188 ]
Bowen Li edited comment on FLINK-6219 at 10/9/17 4:18 PM: ---------------------------------------------------------- [~fhueske] The new title is much better since the discussion above said we don't need a dedicated sort backend. Besides, I think the dependency in 'Issues Link' is set wrong. This ticket shows to be a dependency of FLINK-6204 but 6204 is already finished. I reopened this ticket. Maybe you can correct the dependencies of issues, or add some explanation here? was (Author: phoenixjiangnan): [~fhueske] I think the dependency in 'Issues Link' is set wrong. This ticket shows to be a dependency of FLINK-6204 but 6204 is already finished. I reopened this ticket. Maybe you can correct the dependencies of issues, or add some explanation here? > Add a sorted state primitive > ---------------------------- > > 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 primitive 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.4.14#64029)