Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms.windowing
Class BoundedWindow
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.windowing.BoundedWindow
-
- Direct Known Subclasses:
- GlobalWindow, IntervalWindow
public abstract class BoundedWindow extends Object
ABoundedWindow
represents a finite grouping of elements, with an upper bound (larger timestamps represent more recent data) on the timestamps of elements that can be placed in the window. This finiteness means that for every window, at some point in time, all data for that window will have arrived and can be processed together.Windows must also implement
Object.equals(java.lang.Object)
andObject.hashCode()
such that windows that are logically equal will be treated as equal byequals()
andhashCode()
.
-
-
Field Summary
Fields Modifier and Type Field and Description static Instant
TIMESTAMP_MAX_VALUE
static Instant
TIMESTAMP_MIN_VALUE
-
Constructor Summary
Constructors Constructor and Description BoundedWindow()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description abstract Instant
maxTimestamp()
Returns the inclusive upper bound of timestamps for values in this window.
-