[ https://issues.apache.org/jira/browse/BEAM-2714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16113021#comment-16113021 ]
Thomas Groh commented on BEAM-2714: ----------------------------------- Effectively, yes; a view is defined by a {{PCollection}} consumed by a {{ParDo}} (or another primitive) that has a {{ViewFn}} associated with the input tag. The runner is responsible for materializing those collections, regardless of any {{CreatePCollectionView}} transform. > ParDo.getAdditionalInputs() return the input of View.CreatePCollectionView > instead of output. > --------------------------------------------------------------------------------------------- > > Key: BEAM-2714 > URL: https://issues.apache.org/jira/browse/BEAM-2714 > Project: Beam > Issue Type: Bug > Components: sdk-java-core > Reporter: Pei He > Assignee: Thomas Groh > Priority: Critical > Fix For: Not applicable > > Attachments: view-tag.png > > > For example, input-pc -> View.AsIterable -> view.out -> ParDo > getInputs() in TransformHierarchy.Node for ParDo will return input-pc instead > of view.out. > I think the code here should make sure the output of view is returned: > https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java#L147 -- This message was sent by Atlassian JIRA (v6.4.14#64029)