Page History

public final class StreamTimeWindows extends Windows<TimeWindow> {
		
		/**
		 * Return a window definition with the given window size.
		 * <p> 
		 * This represents stream time window semantics, which are fixed-size,
		 * gap-less, non-overlapping windows. Static windows use the current
		 * stream time when determining which window an event fits into instead
		 * of the event time (as the other window types use).
		 * <p>
		 * Note that stream time windows will always accept late arriving data, and
		 * should only be used in situations where the ordering of data is not
		 * necessarily important to the semantics of your application.
		 */
		public static StreamTimeWindows ofSize(final Duration size) { ... }
    
}