[FLINK-21061] Introduce RemotePersistedValue construct in Stateful Functions

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: statefun-3.0.0
• Labels: pull-request-available
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 21/Jan/21 07:06
• Updated: 27/Apr/21 18:03
• Resolved: 22/Jan/21 01:45

Description

To prepare for the new cross-language type system upcoming in Stateful Functions, we need a new RemotePersistedValue state construct to support this in the runtime.

A RemotePersistedValue should translate to a Flink ValueState that is essentially a byte array value, and persists in state serializer snapshots a typeUrl metainfo to represent the type of the remote value.

Issue Links

• links to: GitHub Pull Request #193