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-3614) Remove Non-Keyed Window Operator
Date Tue, 15 Mar 2016 10:01:33 GMT
Aljoscha Krettek created FLINK-3614:
---------------------------------------

             Summary: Remove Non-Keyed Window Operator
                 Key: FLINK-3614
                 URL: https://issues.apache.org/jira/browse/FLINK-3614
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek


I propose to remove the special Non-Keyed Window Operator and implement non-parallel windows
by using the standard WindowOperator with a dummy KeySelector.

Maintaining everything for two WindowOperators is a huge burden. The implementation is completely
separate by now. For example, the Non-Keyed window operator does not use the StateBackend
for state, i.e. cannot use RocksDB. Also, with upcoming changes (Merging/Session windows,
aligned windows) this will only increase the maintenance burden.

Also, the fast AlignedProcessingTimeWindows operators also only support the Parallel/Keyed
case.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message