public abstract class BoundedWindow extends java.lang.Object
BoundedWindowrepresents window information assigned to data elements.
It has one method
maxTimestamp() to define an upper bound (inclusive) for element
WindowFn must assign an element only to windows where
maxTimestamp() is greater than or equal to the element timestamp. When the watermark passes the
maximum timestamp, all data for a window is estimated to be received.
A window does not need to have a lower bound. Only the upper bound is mandatory because it governs management of triggering and discarding of the window.
Windows must also implement
Object.hashCode() such that
windows that are logically equal will be treated as equal by
|Modifier and Type||Field and Description|
The maximum value for any Beam timestamp.
The minimum value for any Beam timestamp.
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns the inclusive upper bound of timestamps for values in this window.
public static final Instant TIMESTAMP_MIN_VALUE
This value and
TIMESTAMP_MAX_VALUE are chosen so that their
microseconds-since-epoch can be safely represented with a