[
https://issues.apache.org/jira/browse/FLINK-2922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14976143#comment-14976143
]
Aljoscha Krettek edited comment on FLINK-2922 at 10/27/15 10:13 AM:
--------------------------------------------------------------------
I attached a design doc.
was (Author: aljoscha):
Design Doc
> 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
> Assignee: 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.4#6332)
