GitHub user ShunxinLu reopened a pull request:
https://github.com/apache/apex-malhar/pull/414
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 536b6399dcf76c5ffac5b650e78196fecd1f287d
Author: Shunxin <[email protected]>
Date: 2016-09-29T22:37:22Z
APEXMALHAR-2240 Implement Windowed Join Operator
commit 73abf2f614080731b9d8c3010e9be9c7c003ea45
Author: David Yan <[email protected]>
Date: 2016-09-26T23:47:11Z
Introduced WindowedJoinOperatorFeatures classes to solve the problem of
code duplication
----
---
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.
---
