GitHub user charlesccychen opened a pull request:
https://github.com/apache/beam/pull/3157
[BEAM-1265] Do not merge: streaming scratch work
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like:
`[BEAM-<Jira issue #>] Description of pull request`
- [ ] Make sure tests pass via `mvn clean verify`.
- [ ] Replace `<Jira issue #>` in the title with the actual Jira issue
number, if there is one.
- [ ] If this contribution is large, please file an Apache
[Individual Contributor License
Agreement](https://www.apache.org/licenses/icla.pdf).
---
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/charlesccychen/beam streaming-test
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/3157.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 #3157
----
commit f78e47ca47e19ac2684c13bf13dbb66e65f04048
Author: Charles Chen <[email protected]>
Date: 2017-04-19T01:20:07Z
streaming test
commit dd3966a572b73ffa9421a176cc03f096707cdb0d
Author: Charles Chen <[email protected]>
Date: 2017-04-20T05:54:02Z
Working TestStream evaluator
commit 68b5a84595f4ca9adc131fe2fcee38f91078a047
Author: Charles Chen <[email protected]>
Date: 2017-04-20T08:59:05Z
Slightly better watermark propagation, debugging print cleanup.
commit 48d4f1ef68829e98e964070f60ce9470528fcb0e
Author: Charles Chen <[email protected]>
Date: 2017-04-20T09:44:19Z
Factor out GroupAlsoByWindows so that it can be overridden by the
DirectRunner.
commit b5e7073b66c02f634a4bdec8f787b38bb923d52a
Author: Charles Chen <[email protected]>
Date: 2017-04-21T05:51:27Z
Don't buffer elements in GroupByKeyOnly.
commit f81c2d0b536e2715fe4cd278359eed5c6a855dc5
Author: Charles Chen <[email protected]>
Date: 2017-04-21T17:33:03Z
Skeleton implementation of GroupAlsoByKeyEvaluator.
commit 05bd9c677c89d3d3413c205a2965ec0cc6827786
Author: Charles Chen <[email protected]>
Date: 2017-04-22T08:32:25Z
Mostly working streaming GroupAlsoByWindow.
commit f9197ff807d27e61eef337b261f826d5f4b43908
Author: Charles Chen <[email protected]>
Date: 2017-04-24T08:58:58Z
Introduce keyed bundles, KeyedWorkItems.
commit c4b6faf9a4b8231616ec35ec2fd766b863e7a76e
Author: Charles Chen <[email protected]>
Date: 2017-04-24T15:16:05Z
Rename old non-keyed state to legacy_state, introduce KeyedWorkItem,
prepare to expose DirectUnmergedState API.
----
---
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.
---
