Stephan Ewen created FLINK-2676:
-----------------------------------
Summary: Add abstraction for keyed window state
Key: FLINK-2676
URL: https://issues.apache.org/jira/browse/FLINK-2676
Project: Flink
Issue Type: Sub-task
Components: Streaming
Affects Versions: 0.10
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Fix For: 0.10
This abstraction should help to seamlessly switch between window state kept as
- Heap-resident maps
- Managed memory spillable maps
- key/value state backend state
I would approach this abstraction once we implemented a few window operators
and see what operations we need, such as
- Drop time-regions across all keys
- Append to state for key
- Update/replace state by key
- Iterate over unions of multiple state time regions
- snapshot time regions completely / incrementally
- (possibly more)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
