GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/319
REVIEW ONLY: Operator supporting the Beam concepts of windowing,
watermarks, triggering and accumulation
This review-only PR contains the interfaces and a first rough draft of the
implementation of the operator that supports the concepts of windowing,
watermarks, triggering and accumulation mode specified by the Apache Beam API.
Note that this is a rough first draft and it's not supposed to be merged.
When you review this PR, please:
- ignore code style, missing copyright, missing javadoc, missing newline at
EOF, etc. for now
- focus only on java files in the packages
org.apache.apex.malhar.stream.window and
org.apache.apex.malhar.stream.window.impl for now. if you have comments on
changes outside of these two packages, please do so here:
https://github.com/apache/apex-malhar/pull/316
- focus only on the semantics of those java files
- note the TODO comments
thank you.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/davidyan74/apex-malhar windowedOperator
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-malhar/pull/319.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 #319
----
commit 45d56b474567e24205c5e47db4bca3cce9ea5485
Author: Siyuan Hua <hsy...@apache.org>
Date: 2016-06-09T01:06:40Z
High-level WindowedStream API
commit 0de0587d226cf1a0d96b3c0ed9de8ccb325537aa
Author: David Yan <da...@datatorrent.com>
Date: 2016-06-13T19:13:10Z
APEXMALHAR-2085 First draft of windowed operator interfaces
commit e1460f784391d4e01a1c3cbb0d49bb5aa6f60dd3
Author: David Yan <da...@datatorrent.com>
Date: 2016-06-14T19:44:26Z
first try of implementation
----
---
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.
---
