THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
public final class SlidingWindows { /** * Return a window definition with the window size based on the given maximum time difference between records in the same window * and given window grace period * Records that come after set grace period will be ignored * * @param timeDifference, Thethe max time difference between two records in a window * @param grace, Thethe grace period to admit out-of-order events to a window * @return a new window definition * @throws IllegalArgumentException if the specified time difference or grace is zero or negative or can't be represented as {@code long milliseconds} */ public static SlidingWindows withTimeDifferenceAndGrace(final Duration timeDifference, final Duration grace) throws IllegalArgumentException{} |
...