THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
To resolve this conflict, we're adding a new concept to the window spec: grace period. This is an amount of time that the window should accept late-arriving events after the window ends. After the grace period passes, the window is considered "closed" and will never be updated again. The grace period places a lower-bound constraint on the retention time, but otherwise has no implication on retention.
We will add a "grace()" configuration to the window spec builders (Windows, TimeWindows, JoinWindows, UnlimitedWindows, and SessionWindows).
We are also deprecating the retention time and segment interval as specified on the window spec itself and moving them to the lower-level store configurations.
| No Format |
|---|
+ On TimeWindows, JoinWindows, SessionWindows: /** + * Reject late events that arrive more than {@code millisAfterWindowEnd} + * after the end of its window. + * * + Lateness is defined as (stream_time - record_timestamp). * * @param millisAfterWindowEnd The grace period to admit late-arriving events to a window. + * @return this updated builder + */ + public Windows<W>@SuppressWarnings("deprecation") // will be fixed when we remove segments from Windows public XWindows grace(final long millisAfterWindowEnd); // where XWindows is the appropriate builder On Windows (and SessionWindows, although it's not abstract there): + /** + * Return the window grace period (the time to admit + * late-arriving events after the end of the window. + */ + public abstract long gracePeriodMs(); /** ... + * @deprecated since 2.1. Use {@link Joined#retention()} + * or {@link Materialized#retention} + * or directly configure the retention in a store supplier and use + * {@link Materialized#as(WindowBytesStoreSupplier)}. */ + @Deprecated public Windows<W> until(final long durationMs); /** ... * @deprecated since 2.1. Use {@link Joined#retention()} or {@link Materialized#retention} instead. */ @Deprecated public long maintainMs(); /** ... * @deprecated since 2.1. Instead, directly configure the segment interval in a store supplier and use {@link Materialized#as(WindowBytesStoreSupplier)}. */ @Deprecated public long segmentInterval(); |
...