Tanay Tummalapalli created BEAM-7388:
----------------------------------------

             Summary: Reify PTransform for Python SDK
                 Key: BEAM-7388
                 URL: https://issues.apache.org/jira/browse/BEAM-7388
             Project: Beam
          Issue Type: Improvement
          Components: sdk-py-core
    Affects Versions: 2.12.0
            Reporter: Tanay Tummalapalli


The Java SDK has a nice [Reify 
PTransform|https://beam.apache.org/releases/javadoc/2.4.0/org/apache/beam/sdk/transforms/Reify.html]
 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|https://github.com/apache/beam/pull/8589].

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



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to