Page History

public final class BatchedWindows extends Windows<TimeWindow> {
		
		/**
		 * Return a window definition with the given window size.
		 * <p> 
		 * This represents stream"batching" time window semantics, which are fixed-size,
		 * gap-less, non-overlapping windows. StaticBatched 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). This allows users
         * to batch together records of the same key over a window of time.
		 * <p>
		 * Note that offset orderedbatched 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 BatchedWindows ofSize(final Duration size) { ... }
    
}