[ https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884862#comment-15884862 ]
Konstantin Knauf commented on FLINK-2922: ----------------------------------------- [~uce] Is there a design doc/branch for current work on this topic? I thought a little about adding support for an API like WindowedStream::asQueryableState(ReduceFunction ...) and related methods. So, I would be interested on the current state and direction of your implementation? > Add Queryable Window Operator > ----------------------------- > > Key: FLINK-2922 > URL: https://issues.apache.org/jira/browse/FLINK-2922 > Project: Flink > Issue Type: Improvement > Components: Streaming > Reporter: Aljoscha Krettek > Labels: requires-design-doc > Attachments: FLINK-2922.pdf > > > The idea is to provide a window operator that allows to query the current > window result at any time without discarding the current result. > For example, a user might have an aggregation window operation with tumbling > windows of 1 hour. Now, at any time they might be interested in the current > aggregated value for the currently in-flight hour window. > The idea is to make the operator a two input operator where normal elements > arrive on input one while queries arrive on input two. The query stream must > be keyed by the same key as the input stream. If an input arrives for a key > the current value for that key is emitted along with the query element so > that the user can map the result to the query. -- This message was sent by Atlassian JIRA (v6.3.15#6346)