[
https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15883083#comment-15883083
]
Aljoscha Krettek commented on FLINK-2922:
-----------------------------------------
This issue was closed because [~uce] was working on a general way of making
internal state queryable. You're right though, that the window operator state
is right now not queryable using the queryable state API.
> 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)
