[BEAM-7388] Reify PTransform for Python SDK

• Type: Improvement
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Affects Version/s: 2.12.0
• Fix Version/s: 2.14.0
• Component/s: sdk-py-core
• Labels: patch starter
• Assignee: Tanay Tummalapalli
• Reporter: Tanay Tummalapalli
• Created: 22/May/19 18:46
• Updated: 16/May/20 13:20
• Resolved: 05/Jun/19 17:24

Description

The Java SDK has a nice Reify PTransform that can be used to add timestamp, window info to elements of a PCollection. This makes adding timestamp, window info reusable and easy instead of defining DoFns every time.

Also, this can make a pipeline look really neat. Eg: This PR.

This can be added to the util module of the Python SDK.

Issue Links

• duplicates: BEAM-7019 Reify transform for Python SDK
• links to: GitHub Pull Request #8717