THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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:
...