Details
-
Improvement
-
Status: Open
-
Minor
-
Resolution: Unresolved
-
None
-
None
-
None
Description
For example, TWindow.batch clearly provides batch functionality for tuples in the partition – tuples are processed in bulk, and then evicted.
The contract for TWindow.aggregate is less clear given the name. The way it currently works, the partition is aggregated any time its contents change (a tuple is inserted or evicted).
Perhaps something like TWindow.aggregateOnChange would be better?