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 | 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. |
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()