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.
---
