THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Rather than adapt the existing TimeWindows interface (which provides semantics for tumbling and hopping windows), I propose to add a separate SlidingWindows class. This will resemble a stripped-down version of the TimeWindows class, and have only one public method:
Code Block | ||
---|---|---|
| ||
public final class SlidingWindows extends Windows<TimeWindow> { public static SlidingWindows of(final Duration size); } |
This would effectively be used in the same manner as TimeWindows. For example to do a counting aggregation with sliding windows, you would have something like
...