From 4cef2cbc595af1bbd68255d5404fabf8f57c699b Mon Sep 17 00:00:00 2001 From: James Xu Date: Tue, 30 May 2017 11:27:32 +0800 Subject: [PATCH] fix javadoc of View --- .../src/main/java/org/apache/beam/sdk/transforms/View.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 bcbdb24d5290..073c750901da 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 @@ * {@code * PCollection pages = ... // pages fit into memory * PCollection urlVisits = ... // very large collection - * final PCollectionView> = urlToPage + * final PCollectionView> urlToPageView = pages * .apply(WithKeys.of( ... )) // extract the URL from the page * .apply(View.asMap()); * * PCollection PageVisits = urlVisits - * .apply(ParDo.withSideInputs(urlToPage) + * .apply(ParDo.withSideInputs(urlToPageView) * .of(new DoFn() { * {@literal @}Override * void processElement(ProcessContext context) { * UrlVisit urlVisit = context.element(); + * Map urlToPage = context.sideInput(urlToPageView); * Page page = urlToPage.get(urlVisit.getUrl()); * c.output(new PageVisit(page, urlVisit.getVisitData())); * }