GitHub user vjagadish1989 opened a pull request:
https://github.com/apache/samza/pull/66
Implementation of Windows and various kinds of Triggers (WIP)
* Implemented various triggers and the orchestration logic of the window
operator.
* Implemented wire-up of window and the flow of messages through various
trigger implementations.
* Implementations for count, time, timeSinceFirst, timeSinceLast, Any,
Repeating triggers.
Pending:
- More tests.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vjagadish1989/samza window-impl
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/66.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 #66
----
commit 8895e677f550a447d9e857199ef719efb144056b
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-24T02:37:08Z
add trigger implementation
commit cc47ed1bf6c8ae3b9d3de66218e8fa987cdd2aa9
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-24T19:47:20Z
fix to get a test passing
commit 66d3400a20ecda6a98fef0cdaf2b7534f068d92b
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-24T23:18:31Z
Fix more tests. make triggers cancellable
commit 39981bbd8b3f44a38b44ca3a86736a0ad5f65122
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-26T22:58:52Z
Add more docs.
commit d26b6cdadd83588c528a7e860019f566ab454abf
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-26T23:00:30Z
more docs
commit 5d31664fdf1358f1a455cfc5997da1c7b8931e85
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-26T23:02:48Z
more docs
commit e82063b6306898b5902198fc7b7e326b7d568aa6
Author: vjagadish1989 <jvenk...@linkedin.com>
Date: 2017-02-26T23:29:25Z
added more documentation
----
---
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.
---
