...
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 */ @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(); |
Note for UnlimitedWindows in particular, the grace period is meaningless because the window never ends. Therefore, we provide this interface instead:
No Format |
---|
/**
* Throws an {@link IllegalArgumentException} because the window never ends and the
* grace period is therefore meaningless.
*
* @throws IllegalArgumentException on every invocation
*/
@Override
public Windows<UnlimitedWindow> grace(final long millisAfterWindowEnd); |
The Window/Session BytesStoreSupplier interface already includes retention period. The existing behavior is that that retention period overrides maintainMs if set on the window. We'll preserve this behavior.
...