[
https://issues.apache.org/jira/browse/FLINK-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-12693.
----------------------------------
Resolution: Implemented
Merged in:
master: 8f47b38
> Store state per key-group in CopyOnWriteStateTable
> --------------------------------------------------
>
> Key: FLINK-12693
> URL: https://issues.apache.org/jira/browse/FLINK-12693
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / State Backends
> Reporter: Yu Li
> Assignee: PengFei Li
> Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Since we propose to use KeyGroup as the unit of spilling/loading, the first
> step is to store state per key-groups. Currently {{NestedMapsStateTable}}
> natively supports this, so we only need to refine {{CopyOnWriteStateTable}}
> The main efforts required here is to extract the customized hash-map out of
> {{CopyOnWriteStateTable}} then use such a hash-map as the state holder for
> each KeyGroup. Whereafter we could extract some common logic out into
> {{StateTable}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
