GitHub user satishd opened a pull request:
https://github.com/apache/storm/pull/1072
STORM-676 Trident windowing implementation
This PR adds windowing support in a trident stream.
- Added support of sliding and tumbling windows based on count of tuples
and duration through window operations on stream.
- This functionality uses a WindowsStore implementation which stores
tuples, and aggregated results.
- HBase store provider is implemented. It can be enhanced with user
configuration or extending the basic implementation. Other providers can be
added by implementing the required interfaces.
- More details can be found at
- https://issues.apache.org/jira/browse/STORM-676
-
https://issues.apache.org/jira/secure/attachment/12780751/StormTrident_windowing_support-676.pdf
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/satishd/storm STORM-676
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1072.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 #1072
----
commit 20d46ae12dcc3a7b94c814983d9ecd138de8fd3c
Author: Satish Duggana <[email protected]>
Date: 2016-01-17T10:26:33Z
STORM:676 Trident windowing 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 [email protected] or file a JIRA ticket
with INFRA.
---
