Stephan Ewen created FLINK-2753:
-----------------------------------
Summary: Add new window API to streaming API
Key: FLINK-2753
URL: https://issues.apache.org/jira/browse/FLINK-2753
Project: Flink
Issue Type: Sub-task
Components: Streaming
Affects Versions: 0.10
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Fix For: 0.10
The API integration should follow the API design as documented here:
https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams
This issue needs:
- Add new {{KeyedWindowDataStream}}, created by calling{{window()}} on the
{{KeyedDataStream}}.
- Add a utility that converts Window Policies into concrete window
implementations. This is important to realize special case implementations that
do not directly use generic mechanisms implemented by window policies.
- Instantiating the operators (dedicated and generic) from the window policies
- I will add a stub for the new Window Policy classes, based on the existing
policy classes.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
