[
https://issues.apache.org/jira/browse/FLINK-12790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12790:
-----------------------------
Description: As mentioned in the design document, to distinguish the method
calling between {{localKeyBy}} and general {{keyBy}} API in {{KeyedStream}}.
That means the key scope is also used to distinguish the local keyed state and
global keyed state. In addition, the implementation of state backend would be
refined based on the key scope. (was: As mentioned in the design document, to
distinguish the method calling between {{localKeyBy}} and general {{keyBy}} API
in {{KeyedStream}}. Also, the implementation of state backend would be refined
based on the key scope.)
> Implement KeyScope enum to distinguish the key of localKeyBy and general
> keyBy API
> ----------------------------------------------------------------------------------
>
> Key: FLINK-12790
> URL: https://issues.apache.org/jira/browse/FLINK-12790
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / State Backends
> Reporter: vinoyang
> Assignee: vinoyang
> Priority: Major
>
> As mentioned in the design document, to distinguish the method calling
> between {{localKeyBy}} and general {{keyBy}} API in {{KeyedStream}}. That
> means the key scope is also used to distinguish the local keyed state and
> global keyed state. In addition, the implementation of state backend would be
> refined based on the key scope.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
