flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2922) Add Queryable Window Operator
Date Mon, 26 Oct 2015 14:57:27 GMT
Aljoscha Krettek created FLINK-2922:
---------------------------------------

             Summary: 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


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)

Mime
View raw message