You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:13:46 UTC
[jira] [Created] (FLINK-2676) Add abstraction for keyed window
state
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)