[
https://issues.apache.org/jira/browse/S4-57?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13418419#comment-13418419
]
Matthieu Morel commented on S4-57:
----------------------------------
I just uploaded an API update based on Leo's comments. Available in branch
S4-57 (changes rebased on top of piper branch, and forcefully pushed to the
S4-57 remote branch)
* Slot has a method for closing it
* Slot instances are provided by a SlotFactory
* Slot management is automatic: when a boundary is reached, the platform closes
the current slot and adds a new one, created through the factory
* count-based slots are created through a trigger (we could use the same
mechanism for time based)
* AbstractSlidingWindowPE has a method for computing an aggregation over the
whole window. It could potentially be used for automating the output of the PE.
* update method is called on the PE (which delegates to the current slot)
> Document and improve the windowing PE
> -------------------------------------
>
> Key: S4-57
> URL: https://issues.apache.org/jira/browse/S4-57
> Project: Apache S4
> Issue Type: Improvement
> Affects Versions: 0.5
> Reporter: Matthieu Morel
>
> org.apache.s4.core.WindowingPE provides a generic facility for handling
> sliding stream windows.
> We should add some examples, regression tests, and improve usability. In
> particular it is crucial to ease the management of concurrent accesses to the
> window's data.
> In addition, we may also want to allow sizing the window on the number of
> events, not only by time intervals.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
