[FLINK-12790] Implement KeyScope enum to distinguish the key of localKeyBy and general keyBy API

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Runtime / State Backends
• Labels: auto-unassigned pull-request-available
• Assignee: Unassigned
• Reporter: vinoyang
• Created: 10/Jun/19 06:44
• Updated: 27/Apr/21 23:03

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. 

Issue Links

• links to: GitHub Pull Request #8684