Repository: beam Updated Branches: refs/heads/master 711faffef -> aff406b89
fix javadoc of View Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dd79d5aa Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dd79d5aa Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/dd79d5aa Branch: refs/heads/master Commit: dd79d5aac3b44a6cb9569d6fb4f30e10335ab66d Parents: 711faff Author: James Xu <[email protected]> Authored: Tue May 30 11:27:32 2017 +0800 Committer: Dan Halperin <[email protected]> Committed: Tue May 30 09:11:39 2017 -0700 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/beam/sdk/transforms/View.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/dd79d5aa/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java index bcbdb24..073c750 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java @@ -116,16 +116,17 @@ import org.apache.beam.sdk.values.PCollectionViews; * {@code * PCollection<Page> pages = ... // pages fit into memory * PCollection<UrlVisit> urlVisits = ... // very large collection - * final PCollectionView<Map<URL, Page>> = urlToPage + * final PCollectionView<Map<URL, Page>> urlToPageView = pages * .apply(WithKeys.of( ... )) // extract the URL from the page * .apply(View.<URL, Page>asMap()); * * PCollection PageVisits = urlVisits - * .apply(ParDo.withSideInputs(urlToPage) + * .apply(ParDo.withSideInputs(urlToPageView) * .of(new DoFn<UrlVisit, PageVisit>() { * {@literal @}Override * void processElement(ProcessContext context) { * UrlVisit urlVisit = context.element(); + * Map<URL, Page> urlToPage = context.sideInput(urlToPageView); * Page page = urlToPage.get(urlVisit.getUrl()); * c.output(new PageVisit(page, urlVisit.getVisitData())); * }
