Page History

...

Sliding window aggregation to create windows of twenty seconds with a grace period of 30 seconds.

(NoteNotes: grace will be required in SlidingWindows instead of implementing the 24 hour default seen in TimeWindows and SessionWindows. It will also be required to use a Timestamped Window Store, as calculating the sliding windows relies the extra information stored in a Timestamped Window Store. A different type of store will throw an exception):

stream
	.groupByKey()
	.windowedBy(SlidingWindows.of(ofSeconds(20), ofSeconds(30))
	.toStream()

...