[jira] [Commented] (BEAM-920) Support triggers, panes and watermarks.

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888988#comment-15888988
 ] 

ASF GitHub Bot commented on BEAM-920:
-

Github user asfgit closed the pull request at:

https://github.com/apache/beam/pull/2050


> 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)

[jira] [Commented] (BEAM-920) Support triggers, panes and watermarks.

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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-] 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 `` 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 
Date:   2017-02-13T14:30:16Z

Better name for batch implementation of GroupAlsoByWindow.

commit 9bb666f794b3179683f1e70e93fb4cf7e7ad7067
Author: Sela 
Date:   2017-02-13T14:32:21Z

Implementation of GroupAlsoByWindowViaWindowSet for the Spark runner.

commit 1bdc69ae84b39ef8b71f095a5ac14f0bfeca38ef
Author: Sela 
Date:   2017-02-13T14:33:14Z

Utils for SparkGroupAlsoByWindowViaWindowSet.

commit 7b93356216d174cb4e2ced46e7a58de9932ac8b6
Author: Sela 
Date:   2017-02-16T23:19:23Z

Refactor translators according to new GroupAlsoByWindow implemenation for 
the Spark runnner.

commit 9a87206c1750b6c92f2787fd991d9d5b519e5a4f
Author: Sela 
Date:   2017-02-18T20:01:58Z

Fix streaming translation of Flatten and Window, make CreateStream eager.

commit 2a9fdd914e017a42b4b8a07937294d67324f4a3a
Author: Sela 
Date:   2017-02-18T20:05:19Z

Test triggers, panes and watermarks via CreateStream.

commit 9f15cf81c7469431d08c0f297d496edc6c85d86f
Author: Sela 
Date:   2017-02-18T20:06:51Z

Remove streaming tests that were needed before supporting the model.

commit 01a4da64ca328645e78c74edde3375326d8c
Author: Sela 
Date:   2017-02-18T20:10:50Z

Use TestSparkRunner in tests.

commit 700907ff0757b25f20d3acb83eff715359775c5e
Author: Sela 
Date:   2017-02-18T20:12:39Z

Handle test failures in "graceful stop peroid".

commit 1b21ed4594ccba1a6cb249433f577374f19dc531
Author: Sela 
Date:   2017-02-18T20:13:29Z

Further refactoring following changes.

commit bfe6594143a2cd830c5a7a2a2923a906c9855ac2
Author: Sela 
Date:   2017-02-19T22:13:23Z

Serialize state stream with coders for shuffle and checkpointing.

commit 173e29b0ad70b2f891ab6c74b740850eb6c01139
Author: Sela 
Date:   2017-02-19T22:14:39Z

Add multi stream and flattened stream tests.

commit 4cfa372927bc77c74469de702eb13efe70560650
Author: Sela 
Date:   2017-02-20T12:00:54Z

Misc. fixups.

commit 5788190aed2def9b8028f3759d160b2d38f32547
Author: Sela 
Date:   2017-02-20T17:45:03Z

Make TimestampTransform Serializable.

commit 462f7b22b94d3528fff0a086f87a25630b748ca1
Author: Sela 
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)

[jira] [Commented] (BEAM-920) Support triggers, panes and watermarks.

[ASF GitHub Bot (JIRA)]

[ 
https://issues.apache.org/jira/browse/BEAM-920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15874291#comment-15874291
 ] 

ASF GitHub Bot commented on BEAM-920:
-

Github user asfgit closed the pull request at:

https://github.com/apache/beam/pull/1987


> 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)