flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4856) Add MapState for keyed streams
Date Thu, 23 Feb 2017 16:07:46 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15880729#comment-15880729

ASF GitHub Bot commented on FLINK-4856:

Github user aljoscha commented on the issue:

    Thanks a lot for working on this @shixiaogang. ! 😃 
    I just merged your PR, could you please close is.

> Add MapState for keyed streams
> ------------------------------
>                 Key: FLINK-4856
>                 URL: https://issues.apache.org/jira/browse/FLINK-4856
>             Project: Flink
>          Issue Type: New Feature
>          Components: DataStream API, State Backends, Checkpointing
>            Reporter: Xiaogang Shi
>            Assignee: Xiaogang Shi
>             Fix For: 1.3.0
> Many states in keyed streams are organized as key-value pairs. Currently, these states
are implemented by storing the entire map into a ValueState or a ListState. The implementation
however is very costly because all entries have to be serialized/deserialized when updating
a single entry. To improve the efficiency of these states, MapStates are urgently needed.

This message was sent by Atlassian JIRA

View raw message