[BEAM-2687] Python SDK support for Stateful Processing

• Type: New Feature
• Status: Resolved
• Priority: P2
• Resolution: Implemented
• Fix Version/s: 2.9.0
• Component/s: sdk-py-core
• Assignee: Unassigned
• Reporter: Ahmet Altay
• Created: 27/Jul/17 04:52
• Updated: 16/May/20 13:52
• Resolved: 15/Feb/19 00:30

Description

Python SDK should support stateful processing (https://beam.apache.org/blog/2017/02/13/stateful-processing.html)

In the meantime, runner capability matrix should be updated to show the lack of this feature (https://beam.apache.org/documentation/runners/capability-matrix/)

Use this as an umbrella issue for all related issues.

Issue Links

• incorporates: BEAM-7035 Clear() method of OutputTimer is inconsistent
• is blocked by: BEAM-4594 Implement Beam Python User State and Timer API
• links to: GitHub Pull Request #6349
• links to: GitHub Pull Request #6433
• links to: GitHub Pull Request #6579
• links to: GitHub Pull Request #7102