GitHub user siyuanh opened a pull request:
https://github.com/apache/apex-malhar/pull/339
Windowed Strea
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 7a77274a2bc3147d9a72886649bfe904c77a903f
Author: David Yan <[email protected]>
Date: 2016-06-23T21:37:29Z
APEXMALHAR-2085 windowed operator interfaces and implementation
addressing PR comments
Added trigger unit tests
Fixed sliding window bug, added unit tests
Fixed session window bug; added more unit tests
Gives window a chance to trigger before purging because of lateness
added more unit tests
Process watermark only at end window
Renamed WatermarkOpt to Type, and fixed bug when window in retraction
storage is not dropped when it's too late
added copyright
rat check
changed WindowOption from an abstract class to an interface
Use mutable objects for accumulated types
Retraction storage needs to be based on the output, not accumulated type
Added more unit tests
added support of fixed lateness in case watermark is not available from
upstream
changed name from fixed lateness to fixed watermark
support inheriting windowed tuple from upstream when window option is not
given
commit 95657d2c07b1103212e42007cebfa16c4819c6d1
Author: Siyuan Hua <[email protected]>
Date: 2016-07-12T18:50:30Z
Merge branch 'windowedOperator' of
https://github.com/davidyan74/incubator-apex-malhar into WindowedStream
commit 7db0f551c22dd345f0c6340fe2c68882984f8cac
Author: Siyuan Hua <[email protected]>
Date: 2016-07-12T18:57:09Z
APEXMALHAR-2085 High-level WindowedStream API
----
---
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.
---
