...
Another important think to note is, that a new aggregation will be calculated, when a new event arrives a the system. For this example it take 8 seconds before the first value is created. For streams with a low data rate the AssureHeartbeat operator can be used to produce values on a regular base.
...
Note: If the stream has a low data rate, it may take very long before the first elements are created!
TODO: Example for Partition Window
Group By
TODO and Partition Window
Predicate Based Window
The most generic way to define windows