[ 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)