You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "David Moravek (Jira)" <ji...@apache.org> on 2019/11/29 07:39:00 UTC

[jira] [Created] (BEAM-8850) Flink: Batch translation context respects provided PTransform during Input / Output lookups.

David Moravek created BEAM-8850:
-----------------------------------

             Summary: Flink: Batch translation context respects provided PTransform during Input / Output lookups.
                 Key: BEAM-8850
                 URL: https://issues.apache.org/jira/browse/BEAM-8850
             Project: Beam
          Issue Type: Sub-task
          Components: runner-flink
            Reporter: David Moravek
            Assignee: David Moravek


Currently batch translation context uses `currentTransform` for input / ouput lookups, even though we provide a `PTransform` we want to perform lookup for as a parameter.

We need to introduce a new PipelineVisitor, that would be initialized prior translation and build an in-memory PTransform / AppliedPTransform lookup table, that can be used by translation context.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)