Chamikara Jayalath created BEAM-7850:
----------------------------------------

             Summary: Make Environment a top level attribute of PTransform
                 Key: BEAM-7850
                 URL: https://issues.apache.org/jira/browse/BEAM-7850
             Project: Beam
          Issue Type: Improvement
          Components: beam-model
            Reporter: Chamikara Jayalath


Currently Environment is not a top level attribute of the PTransform (of runner 
API proto).

[https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto#L99]

Instead it is hidden inside various payload objects. For example, for ParDo, 
environment will be inside SdkFunctionSpec of ParDoPayload.

[https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto#L99]

 

This makes tracking environment of different types of PTransforms harder and we 
have to fork code (on the type of PTransform) to extract the Environment where 
the PTransform should be executed. It will probably be simpler to just make 
Environment a top level attribute of PTransform.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to