...
We are also deprecating the retention time and segment interval as specified on the window spec itself and moving it them to the lower-level store configurations.
No Format |
---|
+ /**
+ * Reject late events that arrive more than {@code afterWindowEnd}
+ * after the end of its window.
+ *
+ * @param afterWindowEnd The grace period to admit late-arriving events to a window.
+ * @return this updated builder
+ */
+ public Windows<W> grace(final Duration afterWindowEnd);
+ /**
+ * Return the window grace period (the time to admit
+ * late-arriving events after the end of the window.
+ */
+ public Duration grace();
/**
...
+ * @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:
...