[
https://issues.apache.org/jira/browse/BEAM-920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15874874#comment-15874874
]
ASF GitHub Bot commented on BEAM-920:
-------------------------------------
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.
----
> Support triggers, panes and watermarks.
> ---------------------------------------
>
> Key: BEAM-920
> URL: https://issues.apache.org/jira/browse/BEAM-920
> Project: Beam
> Issue Type: New Feature
> Components: runner-spark
> Reporter: Amit Sela
> Assignee: Amit Sela
>
> Implement event-time based aggregation using triggers, panes and watermarks.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
