You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/05/30 16:11:47 UTC
[1/2] beam git commit: fix javadoc of View
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 <xu...@gmail.com>
Authored: Tue May 30 11:27:32 2017 +0800
Committer: Dan Halperin <dh...@google.com>
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()));
* }
[2/2] beam git commit: This closes #3257
Posted by dh...@apache.org.
This closes #3257
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aff406b8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aff406b8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aff406b8
Branch: refs/heads/master
Commit: aff406b894b512eefea648656de5ade181acbbfe
Parents: 711faff dd79d5a
Author: Dan Halperin <dh...@google.com>
Authored: Tue May 30 09:11:42 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Tue May 30 09:11:42 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/transforms/View.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------