incubator-s4-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthieu Morel (JIRA)" <>
Subject [jira] [Commented] (S4-57) Document and improve the windowing PE
Date Thu, 19 Jul 2012 16:35:33 GMT


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
* 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:
>             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
> 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:!default.jspa
For more information on JIRA, see:


View raw message