[BEAM-4594] Implement Beam Python User State and Timer API

• Type: New Feature
• Status: Resolved
• Priority: P2
• Resolution: Implemented
• Fix Version/s: 2.9.0
• Component/s: sdk-py-core
• Labels: portability
• Assignee: Unassigned
• Reporter: Charles Chen
• Created: 20/Jun/18 02:22
• Updated: 16/May/20 14:05
• Resolved: 15/Feb/19 00:28

Description

This issue tracks the implementation of the Beam Python User State and Timer API, described here: https://s.apache.org/beam-python-user-state-and-timers.

Issue Links

• blocks: BEAM-2687 Python SDK support for Stateful Processing
• is blocked by: BEAM-4655 Update pipeline translation for timers inside Python SDK
• is blocked by: BEAM-4657 Python SDK harness should support user timers
• is blocked by: BEAM-5264 Reference DirectRunner implementation of Python user state and timers API
• links to: GitHub Pull Request #5691
• links to: GitHub Pull Request #6470
• links to: GitHub Pull Request #7252
• links to: GitHub Pull Request #7558