W - type of the window instancepublic abstract class Windows<W extends Window> extends Object
Grace period defines how long to wait on out-of-order events. That is, windows will continue to accept new records until stream_time >= window_end + grace_period. Records that arrive after the grace period passed are considered late and will not be processed but are dropped.
Warning: It may be unsafe to use objects of this class in set- or map-like collections, since the equals and hashCode methods depend on mutable fields.
| Modifier and Type | Field and Description |
|---|---|
protected static long | DEPRECATED_DEFAULT_24_HR_GRACE_PERIODBy default grace period is 24 hours for all windows in other words we allow out-of-order data for up to a day This behavior is now deprecated and additional details are available in the motivation for the KIP Check out KIP-633 for more details |
protected static long | NO_GRACE_PERIODThis constant is used as the specified grace period where we do not have any grace periods instead of magic constants |
| Modifier | Constructor and Description |
|---|---|
protected | Windows() |
| Modifier and Type | Method and Description |
|---|---|
abstract long | gracePeriodMs()Return the window grace period (the time to admit out-of-order events after the end of the window.) Delay is defined as (stream_time - record_timestamp). |
abstract long | size()Return the size of the specified windows in milliseconds. |
abstract Map<Long,W> | windowsFor(long timestamp)Create all windows that contain the provided timestamp, indexed by non-negative window start timestamps. |
protected static final long DEPRECATED_DEFAULT_24_HR_GRACE_PERIOD
protected static final long NO_GRACE_PERIOD
public abstract Map<Long,W> windowsFor(long timestamp)
timestamp - the timestamp window should get created forwindowStartTimestamp -> Window entriespublic abstract long size()
public abstract long gracePeriodMs()