[
https://issues.apache.org/jira/browse/APEXMALHAR-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15417940#comment-15417940
]
ASF GitHub Bot commented on APEXMALHAR-2142:
--------------------------------------------
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
----
> High-level API window support
> -----------------------------
>
> Key: APEXMALHAR-2142
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2142
> Project: Apache Apex Malhar
> Issue Type: New Feature
> Reporter: Siyuan Hua
> Assignee: Siyuan Hua
> Fix For: 3.5.0
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
