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 <ans...@paypal.com> Date: 2017-02-13T14:30:16Z Better name for batch implementation of GroupAlsoByWindow. commit 9bb666f794b3179683f1e70e93fb4cf7e7ad7067 Author: Sela <ans...@paypal.com> Date: 2017-02-13T14:32:21Z Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner. commit 1bdc69ae84b39ef8b71f095a5ac14f0bfeca38ef Author: Sela <ans...@paypal.com> Date: 2017-02-13T14:33:14Z Utils for SparkGroupAlsoByWindowViaWindowSet. commit 7b93356216d174cb4e2ced46e7a58de9932ac8b6 Author: Sela <ans...@paypal.com> Date: 2017-02-16T23:19:23Z Refactor translators according to new GroupAlsoByWindow implemenation for the Spark runnner. commit 9a87206c1750b6c92f2787fd991d9d5b519e5a4f Author: Sela <ans...@paypal.com> Date: 2017-02-18T20:01:58Z Fix streaming translation of Flatten and Window, make CreateStream eager. commit 2a9fdd914e017a42b4b8a07937294d67324f4a3a Author: Sela <ans...@paypal.com> Date: 2017-02-18T20:05:19Z Test triggers, panes and watermarks via CreateStream. commit 9f15cf81c7469431d08c0f297d496edc6c85d86f Author: Sela <ans...@paypal.com> Date: 2017-02-18T20:06:51Z Remove streaming tests that were needed before supporting the model. commit 01a4da64ca328645e78c74edde3375326d00008c Author: Sela <ans...@paypal.com> Date: 2017-02-18T20:10:50Z Use TestSparkRunner in tests. commit 700907ff0757b25f20d3acb83eff715359775c5e Author: Sela <ans...@paypal.com> Date: 2017-02-18T20:12:39Z Handle test failures in "graceful stop peroid". commit 1b21ed4594ccba1a6cb249433f577374f19dc531 Author: Sela <ans...@paypal.com> Date: 2017-02-18T20:13:29Z Further refactoring following changes. commit bfe6594143a2cd830c5a7a2a2923a906c9855ac2 Author: Sela <ans...@paypal.com> Date: 2017-02-19T22:13:23Z Serialize state stream with coders for shuffle and checkpointing. commit 173e29b0ad70b2f891ab6c74b740850eb6c01139 Author: Sela <ans...@paypal.com> Date: 2017-02-19T22:14:39Z Add multi stream and flattened stream tests. commit 4cfa372927bc77c74469de702eb13efe70560650 Author: Sela <ans...@paypal.com> Date: 2017-02-20T12:00:54Z Misc. fixups. commit 5788190aed2def9b8028f3759d160b2d38f32547 Author: Sela <ans...@paypal.com> Date: 2017-02-20T17:45:03Z Make TimestampTransform Serializable. commit 462f7b22b94d3528fff0a086f87a25630b748ca1 Author: Sela <ans...@paypal.com> 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---