GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/2339
[BEAM-1805] a new option `asInnerJoin` for CoGroupByKey *INNER_JOIN* is available with [Join](https://github.com/apache/beam/blob/master/sdks/java/extensions/join-library/src/main/java/org/apache/beam/sdk/extensions/joinlibrary/Join.java). However it's limited to two `PCollection`s, it's helpful to add it to `CoGroupByKey` for the case with multiple `PCollection` joined. You can merge this pull request into a Git repository by running: $ git pull https://github.com/XuMingmin/beam BEAM-1805 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/beam/pull/2339.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2339 ---- commit 09df9b5c15dd5b409d9da937225caa073a663255 Author: XuMingmin <xuming...@users.noreply.github.com> Date: 2017-03-15T21:45:17Z Merge pull request #3 from apache/master sync-up code commit 93929873179a04fb0038400d57b55b3779d7b085 Author: XuMingmin <xuming...@users.noreply.github.com> Date: 2017-03-24T23:17:00Z Merge pull request #4 from apache/master sync up code commit 62ff6bd83725414aa2ca11d30a5bd7776afe99fa Author: XuMingmin <xuming...@users.noreply.github.com> Date: 2017-03-27T18:30:44Z Merge pull request #5 from apache/master sync-up code commit 6f087a085094bd2520094ca0c5c540ae74b31542 Author: mingmxu <ming...@ebay.com> Date: 2017-03-27T20:38:45Z initial commit ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---