GitHub user amitsela opened a pull request:
https://github.com/apache/beam/pull/2050
[BEAM-920] Support triggers, panes and watermarks.
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`. (Even better, enable
Travis-CI on your fork and ensure the whole test matrix passes).
- [ ] 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.txt).
---
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/amitsela/beam BEAM-920
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/2050.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 #2050
----
commit f5d23531de20b64164496e39f01bc964176501c6
Author: Sela <[email protected]>
Date: 2017-02-13T14:30:16Z
Better name for batch implementation of GroupAlsoByWindow.
commit 9bb666f794b3179683f1e70e93fb4cf7e7ad7067
Author: Sela <[email protected]>
Date: 2017-02-13T14:32:21Z
Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner.
commit 1bdc69ae84b39ef8b71f095a5ac14f0bfeca38ef
Author: Sela <[email protected]>
Date: 2017-02-13T14:33:14Z
Utils for SparkGroupAlsoByWindowViaWindowSet.
commit 7b93356216d174cb4e2ced46e7a58de9932ac8b6
Author: Sela <[email protected]>
Date: 2017-02-16T23:19:23Z
Refactor translators according to new GroupAlsoByWindow implemenation for
the Spark runnner.
commit 9a87206c1750b6c92f2787fd991d9d5b519e5a4f
Author: Sela <[email protected]>
Date: 2017-02-18T20:01:58Z
Fix streaming translation of Flatten and Window, make CreateStream eager.
commit 2a9fdd914e017a42b4b8a07937294d67324f4a3a
Author: Sela <[email protected]>
Date: 2017-02-18T20:05:19Z
Test triggers, panes and watermarks via CreateStream.
commit 9f15cf81c7469431d08c0f297d496edc6c85d86f
Author: Sela <[email protected]>
Date: 2017-02-18T20:06:51Z
Remove streaming tests that were needed before supporting the model.
commit 01a4da64ca328645e78c74edde3375326d00008c
Author: Sela <[email protected]>
Date: 2017-02-18T20:10:50Z
Use TestSparkRunner in tests.
commit 700907ff0757b25f20d3acb83eff715359775c5e
Author: Sela <[email protected]>
Date: 2017-02-18T20:12:39Z
Handle test failures in "graceful stop peroid".
commit 1b21ed4594ccba1a6cb249433f577374f19dc531
Author: Sela <[email protected]>
Date: 2017-02-18T20:13:29Z
Further refactoring following changes.
commit bfe6594143a2cd830c5a7a2a2923a906c9855ac2
Author: Sela <[email protected]>
Date: 2017-02-19T22:13:23Z
Serialize state stream with coders for shuffle and checkpointing.
commit 173e29b0ad70b2f891ab6c74b740850eb6c01139
Author: Sela <[email protected]>
Date: 2017-02-19T22:14:39Z
Add multi stream and flattened stream tests.
commit 4cfa372927bc77c74469de702eb13efe70560650
Author: Sela <[email protected]>
Date: 2017-02-20T12:00:54Z
Misc. fixups.
commit 5788190aed2def9b8028f3759d160b2d38f32547
Author: Sela <[email protected]>
Date: 2017-02-20T17:45:03Z
Make TimestampTransform Serializable.
commit 462f7b22b94d3528fff0a086f87a25630b748ca1
Author: Sela <[email protected]>
Date: 2017-02-20T17:47:45Z
Rebase leftover fixes.
----
---
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.
---
