GitHub user siyuanh reopened a pull request:
https://github.com/apache/apex-malhar/pull/339
APEXMALHAR-2142 Windowed Stream First Implementation
This is for review only, please ignore all checkstyle violations, format
issue etc.
For windowed operator changes, refer to #319
Please only review the code in stream module.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/siyuanh/apex-malhar WindowedStream
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-malhar/pull/339.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 #339
----
commit d342dc1d2eff931a665e618e90a95cba5afbcc04
Author: Siyuan Hua <[email protected]>
Date: 2016-07-12T18:57:09Z
APEXMALHAR-2142 #comment Implement WindowedStream interface
Add Accumulation interface support to High-Level API
Add @Evolving and name support for all the windowed transforms
commit e3a5a7d5fc32bc257665726f618c990c3a713d5e
Author: Shunxin <[email protected]>
Date: 2016-08-10T18:52:58Z
Added Examples from Beam and implementations of Accumulation.
commit 91012551691dff0dcd382ae59b663ca12b8a58c7
Author: Siyuan Hua <[email protected]>
Date: 2016-08-11T07:11:00Z
fix some small bug
commit 97f063ec99f9426180fab5a8129c76aaf711a55c
Author: Siyuan Hua <[email protected]>
Date: 2016-08-11T20:47:25Z
fix license
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
