[ https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15648131#comment-15648131 ]
Aljoscha Krettek commented on FLINK-5024: ----------------------------------------- [~StephanEwen] I think this should be ok with regards to backwards compatibility once FLINK-5034 is resolved. Btw, your sentence is trailing off: "How about ..." FLINK-5035 might also be relevant but I think it's not required since we don't care where the {{TypeSerializer}} is coming from. > Add SimpleStateDescriptor to clarify the concepts > ------------------------------------------------- > > Key: FLINK-5024 > URL: https://issues.apache.org/jira/browse/FLINK-5024 > Project: Flink > Issue Type: Improvement > Reporter: Xiaogang Shi > Assignee: Xiaogang Shi > > Currently, StateDescriptors accept two type arguments : the first one is the > type of the created state and the second one is the type of the values in the > states. > The concepts however is a little confusing here because in ListStates, the > arguments passed to the StateDescriptors are the types of the list elements > instead of the lists. It also makes the implementation of MapStates difficult. > I suggest not to put the type serializer in StateDescriptors, making > StateDescriptors independent of the data structures of the values. > A new type of StateDescriptor named SimpleStateDescriptor can be provided to > abstract those states (namely ValueState, ReducingState and FoldingState) > whose states are not composited. > The states (e.g. ListStates and MapStates) can implement their own > descriptors according to their data structures. -- This message was sent by Atlassian JIRA (v6.3.4#6332)