GitHub user kennknowles opened a pull request:
https://github.com/apache/incubator-beam/pull/781
[BEAM-498] Port examples to new DoFn
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make sure the PR title is formatted like:
`[BEAM-<Jira issue #>] Description of pull request`
- [x] Make sure tests pass via `mvn clean verify`. (Even better, enable
Travis-CI on your fork and ensure the whole test matrix passes).
- [x] Replace `<Jira issue #>` in the title with the actual Jira issue
number, if there is one.
- [x] If this contribution is large, please file an Apache
[Individual Contributor License
Agreement](https://www.apache.org/licenses/icla.txt).
---
R: @bjchambers pretty nice to be showcasing the `BoundedWindow` parameter
in a couple of them.
Any other reviewer can feel free to LGTM if they are happy with it. It is
pretty mechanical.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kennknowles/incubator-beam examples-new-DoFn
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-beam/pull/781.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 #781
----
commit c31986f5ee31c34538a73057638a45efd796caf5
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T01:54:22Z
Port example tests to new DoFn
commit 8e6c0eaf66d7e5e6f2319aa13efe627b9fe3002a
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:01:16Z
Port TfIdf example to new DoFn
commit c3c42aafc1987d06c55e76e669f8e2c0b7b59b2c
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:03:11Z
Port TopWikipediaSessions example to new DoFn
commit 380f26afc73620abecbd38118095b96f1a91f030
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:04:50Z
Port GameState Java 8 example to new DoFn
commit 1584666cb2c5ef3d8c9edfefe4d8cd7b366ae133
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:06:26Z
Port the UserScore example to new DoFn
commit 86e90246d582327330af7f3212b6ed2c6a4f6af7
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:07:56Z
Port StreamingWordExtract example to new DoFn
commit 30da6afd8d06f63f0a0a7ebafc51e8d30217763c
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:08:19Z
fixup! UserScore
commit 18ee240879a0edc738355746f13b5c6b967babf7
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:09:39Z
Port TrafficMaxLaneFlow to new DoFn
commit 589337562cf59c511dbc49030a88110cbfcd5a3a
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:10:43Z
Port TrafficeRoutes example to new DoFn
commit 616411a1263604182f4cab7e899de3df22fc734d
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:12:08Z
Port DatastoreWordCount example to new DoFn
commit 4878f0b274c656f4d9951f471b7ef346fca58d1f
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:13:19Z
Port BigQueryTornadoes example to new DoFn
commit 480926d9591bfa0dace4af6d6883650bae61bb99
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:13:58Z
Port MaxPerKeyExamples to new DoFn
commit 607ed16fdc38ad19fc711844e0c55da6306d0882
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:14:37Z
Port CombinePerKeyExamples to new DoFn
commit e2262521eb4e84a258bfff03edab1440e91fd9f3
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:15:56Z
Port TriggerExample to new DoFn
commit 8b376606d9a956a2be9b70508010a19d34584d81
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:17:26Z
Port JoinExamples to new DoFn
commit 00e19ae9e690e35e73a0f8aff2bbbbc1a371d80c
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:18:07Z
Port FilterExamples to new DoFn
commit 16b9ca531970b6b32c91229df80926fa0d99714c
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:18:38Z
fixup! TriggerExample
commit ba47f11fb0d1aa99141ab12a4a3665a52d1e016e
Author: Kenneth Knowles <[email protected]>
Date: 2016-08-04T02:19:38Z
Fix mention of DoFn in WordCountTest
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
