[ https://issues.apache.org/jira/browse/GEARPUMP-23?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15508995#comment-15508995 ]
ASF GitHub Bot commented on GEARPUMP-23: ---------------------------------------- GitHub user manuzhang opened a pull request: https://github.com/apache/incubator-gearpump/pull/85 [GEARPUMP-23] add window dsl The PR is opened for early review and the work is in progress with following todos. - [ ] basic window dsl support with `WindowedWordCount` example - [ ] improve `ReduceFunction` to not emit immediate results - [ ] add unit tests - [ ] add comments and update documentation - [ ] support different types of computation (e.g. monoid which doesn't require input elements to be held in the window) You can merge this pull request into a Git repository by running: $ git pull https://github.com/manuzhang/incubator-gearpump window_dsl Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-gearpump/pull/85.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 #85 ---- commit a69554bcdb2620a16107b23d6cee8eb5308a6043 Author: manuzhang <owenzhang1...@gmail.com> Date: 2016-09-08T03:22:18Z [GEARPUMP-23] add window dsl ---- > Add DSL window (time series) support > ------------------------------------- > > Key: GEARPUMP-23 > URL: https://issues.apache.org/jira/browse/GEARPUMP-23 > Project: Apache Gearpump > Issue Type: Sub-task > Components: streaming > Affects Versions: 0.8.0 > Reporter: Kam Kasravi > Assignee: Manu Zhang > > Time series support is need for both GEARPUMP-21 and GEARPUMP-22. This was > originally github issue > [1917|https://github.com/gearpump/gearpump/issues/1917]. Other realtime > streaming engines support time windows such as > [Flink|https://flink.apache.org/news/2015/12/04/Introducing-windows.html], > [Beam|https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-101] and > a future release of > [Spark|https://issues.apache.org/jira/secure/attachment/12793410/StructuredStreamingProgrammingAbstractionSemanticsandAPIs-ApacheJIRA.pdf]. > A comparison matrix is found > [here|https://docs.google.com/spreadsheets/d/1OM077lZBARrtUi6g0X0O0PHaIbFKCD6v0djRefQRE1I/edit#gid=995660187] -- This message was sent by Atlassian JIRA (v6.3.4#6332)