GitHub user ShunxinLu opened a pull request:
https://github.com/apache/apex-malhar/pull/414
REVIEW ONLY: APEXMALHAR-2240 Implement Windowed Join Operator
@davidyan74 @tweise @siyuanh This is the first try of implementing join
support for windowed stream. This PR is for review purpose only, please ignore
all check style errors.
The plan is `WindowedJoinOperator` should support joining up to 5 streams,
but for now it only join 2 streams to verify the implementation.
`KeyedWindowedJoinOperatorImpl` now contains a lot of duplicate code from
`KeyWindowedOperatorImpl`, any suggestion on how to eliminate those
duplications will be appreciated.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ShunxinLu/apex-malhar new_join
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-malhar/pull/414.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 #414
----
commit 88b3625f8188caf944d66e430d8278951c078ebc
Author: Shunxin <[email protected]>
Date: 2016-09-15T22:48:42Z
APEXMALHAR-2240 Implement Windowed Join Operator
----
---
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.
---
